org.reactfx

public Interface SuspenderStream<T, S extends Suspendable>

Known Direct Implementers

extends EventStream<T>, Suspender<S extends Suspendable>org.reactfx.SuspenderStreamImpl

Annotations

@Experimental

Imports

org.reactfx.util.Experimental

An event stream that suspends a suspendable object during emission. More precisely, before a SuspenderStream emits a value, it suspends a Suspendable object and unsuspends it after the emission has completed.

Method Summary

Inherited from org.reactfx.EventStream:: accumulate accumulate accumulate accumulateBetween accumulateBetween accumulateUntilLater accumulateUntilLater accumulateUntilLater accumulateUntilLater accumulateWhen accumulateWhen accumulative accumulative cast conditionOn conditionOnShowing distinct emitBothOnEach emitOn emitOnEach feedTo feedTo filter filter filterMap filterMap flatMap forgetful fork guardedBy hook latestN map mapToCompletionStage mapToTask onRecurseAccumulate onRecurseAccumulate onRecurseQueue onRecurseReduce onRecurseRetainLatest or pausable pauseWhen pin queueBetween queueUntilLater queueUntilLater reduceBetween reduceSuccessions reduceSuccessions reduceSuccessions reduceSuccessions reduceSuccessions reduceSuccessions reduceUntilLater reduceUntilLater reduceWhen reducible repeatOn retainLatestBetween retainLatestUntilLater retainLatestUntilLater retainLatestWhen splitBy subscribe subscribeFor subscribeForOne successionEnds successionEnds supply supply supplyCompletionStage supplyTask suppressible suppressWhen suspenderOf thenAccumulateFor thenAccumulateFor thenAccumulateFor thenAccumulateFor thenIgnoreFor thenIgnoreFor thenReduceFor thenReduceFor thenRetainLatestFor thenRetainLatestFor threadBridge threadBridgeFromFx threadBridgeToFx toBinding withDefaultEvent
Inherited from org.reactfx.Suspender:: getSuspendable