Package org.reactfx
Interface ProperEventStream<T>
- All Superinterfaces:
EventStream<T>
,Observable<Consumer<? super T>>
,ProperObservable<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<Consumer<? super T>,T>
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 TypeMethodDescriptiondefault NotificationAccumulator
<Consumer<? super T>, T, ?> default void
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 Details
-
emit
-
defaultNotificationAccumulator
- Specified by:
defaultNotificationAccumulator
in interfaceProperObservable<Consumer<? super T>,
T>
-