ProperEventStream

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 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

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 interface ProperObservable<java.util.function.Consumer<? super T>,T>