Package org.reactfx
Class EventStreamBase<T>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>
-
- org.reactfx.EventStreamBase<T>
-
- Type Parameters:
T
- type of events emitted by this event stream.
- All Implemented Interfaces:
EventStream<T>
,Observable<java.util.function.Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<java.util.function.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<java.util.function.Consumer<? super T>,T> implements ProperEventStream<T>
Base class for event streams.
-
-
Constructor Summary
Constructors Constructor Description EventStreamBase()
EventStreamBase(NotificationAccumulator<java.util.function.Consumer<? super T>,T,?> pn)
-
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 Detail
-
EventStreamBase
public EventStreamBase()
-
EventStreamBase
EventStreamBase(NotificationAccumulator<java.util.function.Consumer<? super T>,T,?> pn)
-
-