Package org.reactfx
Class EventStreamBase<T>
- Type Parameters:
T
- type of events emitted by this event stream.
- All Implemented Interfaces:
EventStream<T>
,Observable<Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<Consumer<? super T>,
T>
- Direct Known Subclasses:
AccumulateBetweenStream
,AccumulateUntilLaterStream
,AccumulatingStream
,Await
,AwaitLatest
,ConnectableEventSource
,DefaultEventStream
,DistinctStream
,EmitBothOnEachStream
,EmitOnEachStream
,EmitOnStream
,EventSource
,FilterMapStream
,FilterStream
,FlatMapOptStream
,FlatMapStream
,HookStream
,LatestNStream
,MappedStream
,RecursiveStream
,RepeatOnStream
,StatefulStream
,StateStream
,SuccessionReducingStream
,SuspendedWhenStream
,ThenAccumulateForStream
,ThreadBridge
public abstract class EventStreamBase<T>
extends ObservableBase<Consumer<? super T>,T>
implements ProperEventStream<T>
Base class for event streams.
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, observeInputs, removeObserver, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
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.ProperEventStream
defaultNotificationAccumulator, emit
Methods inherited from interface org.reactfx.ProperObservable
defaultEquals, defaultHashCode, defaultToString, notifyObservers
-
Constructor Details
-
EventStreamBase
public EventStreamBase() -
EventStreamBase
EventStreamBase(NotificationAccumulator<Consumer<? super T>, T, ?> pn)
-