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 Type	Method	Description
default NotificationAccumulator<Consumer<? super T>, T, ?>	defaultNotificationAccumulator()
default void	emit(T value)

Methods inherited from interface 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 Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Method Details

emit

default void emit(T value)

defaultNotificationAccumulator

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

Specified by:

defaultNotificationAccumulator in interface ProperObservable<Consumer<? super T>, T>