Barrier

interface Barrier

Defines a utility that can influence whether or not it is safe to continue processing events for any Dispatcher implementations that may rely on this Barrier.

A typical example could be for Dispatchers that may require connectivity, which might use a Connectivity Barrier to control whether or not it should continue processing events.

Updates to the barrier state should be emitted via the onState observable.

Inheritors

Properties

Link copied to clipboard

States whether or not this Barrier can be bypassed for "flush" events.

Functions

Link copied to clipboard
abstract fun onState(dispatcherId: String): Observable<BarrierState>

The flow of this barrier's current state.