Package org.reactfx
Interface ProperEventStream<T>
-
- All Superinterfaces:
EventStream<T>
,Observable<java.util.function.Consumer<? super T>>
,ProperObservable<java.util.function.Consumer<? super T>,T>
- All Known Implementing Classes:
AbstractReducibleEventStream
,AccumulateBetweenStream
,AccumulateUntilLaterStream
,AccumulatingStream
,AccumulativeEventStream
,Await
,AwaitLatest
,ConnectableEventSource
,DefaultEventStream
,DistinctStream
,EmitBothOnEachStream
,EmitOnEachStream
,EmitOnStream
,EventSource
,EventStreamBase
,FilterMapStream
,FilterStream
,FlatMapOptStream
,FlatMapStream
,ForgetfulEventStream
,HookStream
,LatestNStream
,MappedStream
,MappedToCompletionStageStream
,MappedToTaskStream
,PausableEventStream
,RecursiveStream
,ReducibleEventStream
,RepeatOnStream
,StatefulStream
,StateStream
,SuccessionReducingStream
,SuppressibleEventStream
,SuspendableEventStreamBase
,SuspendedWhenStream
,SuspenderStreamImpl
,ThenAccumulateForStream
,ThreadBridge
public interface ProperEventStream<T> extends EventStream<T>, ProperObservable<java.util.function.Consumer<? super T>,T>
Trait to be mixed intoObservableBase
to obtain default implementation of someEventStream
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
All Methods Instance Methods Default Methods Modifier and Type Method Description default NotificationAccumulator<java.util.function.Consumer<? super T>,T,?>
defaultNotificationAccumulator()
default void
emit(T value)
-
Methods inherited from interface 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
-
Methods inherited from interface org.reactfx.Observable
addObserver, observe, removeObserver
-
Methods inherited from interface org.reactfx.ProperObservable
defaultEquals, defaultHashCode, defaultToString, notifyObservers
-
-
-
-
Method Detail
-
emit
default void emit(T value)
-
defaultNotificationAccumulator
default NotificationAccumulator<java.util.function.Consumer<? super T>,T,?> defaultNotificationAccumulator()
- Specified by:
defaultNotificationAccumulator
in interfaceProperObservable<java.util.function.Consumer<? super T>,T>
-
-