onState

abstract fun onState(dispatcherId: String): Observable<BarrierState>

The flow of this barrier's current state.

BarrierState.Closed should be emitted to disallow further processing, and BarrierState.Open to allow processing again.