Barrier Protocol Reference
public protocol Barrier : AnyObjectAn object that will change its state to stop or allow dispatching of events to some dispatchers.
-
The observable of this barrier’s current state for specific dispatcher.
BarrierState.closedshould be emitted to disallow further processing, andBarrierState.opento allow processing again.Declaration
Swift
func onState(for dispatcherId: String) -> Observable<BarrierState>Parameter Description dispatcherIdid of the
Dispatcherwhose barrier state is observed -
States whether or not this
Barriercan be bypassed for “flush” events.Declaration
Swift
var isFlushable: Observable<Bool> { get }Return Value
An
Observablethat emitstrueif thisBarriercan be bypassed; elsefalse.