org.reactfx

public Interface ProperEventStream<T>

Known Direct Implementers: org.reactfx.EventStreamBase, org.reactfx.SuspendableEventStreamBase, org.reactfx.SuspenderStreamImpl
Imports: java.util.function.Consumer, org.reactfx.util.NotificationAccumulator

Trait to be mixed into ObservableBase to obtain default implementation of some EventStream methods on top of Observable methods and get additional helper methods for proper event streams implemented as default methods on top of ProperObservable methods.

Method Summary

Modifier and Type	Method and Description
public default NotificationAccumulator<Consumer<? super T>, T, ?>	defaultNotificationAccumulator() Implements org.reactfx.ProperObservable.defaultNotificationAccumulator.
public default void	emit(T value)

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.ProperObservable:: defaultEquals defaultHashCode defaultToString notifyObservers

Method Detail

defaultNotificationAccumulator	back to summary
public default NotificationAccumulator<Consumer<? super T>, T, ?> defaultNotificationAccumulator() Implements org.reactfx.ProperObservable.defaultNotificationAccumulator. Annotations @Override

defaultNotificationAccumulator

back to summary

public default NotificationAccumulator<Consumer<? super T>, T, ?> defaultNotificationAccumulator()

Implements org.reactfx.ProperObservable.defaultNotificationAccumulator.

Annotations

@Override

emit	back to summary
public default void emit(T value)