Package org.reactfx
Class SuspendableEventStreamBase<T,A>
- java.lang.Object
-
- org.reactfx.ObservableBase<O,T>
-
- org.reactfx.SuspendableBase<java.util.function.Consumer<? super T>,T,A>
-
- org.reactfx.SuspendableEventStreamBase<T,A>
-
- All Implemented Interfaces:
EventStream<T>
,Observable<java.util.function.Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<java.util.function.Consumer<? super T>,T>
,Suspendable
,SuspendableEventStream<T>
- Direct Known Subclasses:
AbstractReducibleEventStream
,AccumulativeEventStream
,PausableEventStream
,SuppressibleEventStream
abstract class SuspendableEventStreamBase<T,A> extends SuspendableBase<java.util.function.Consumer<? super T>,T,A> implements ProperEventStream<T>, SuspendableEventStream<T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SuspendableEventStreamBase(EventStream<T> source, NotificationAccumulator<java.util.function.Consumer<? super T>,T,A> pn)
-
Method Summary
-
Methods inherited from class org.reactfx.SuspendableBase
headOf, initialAccumulator, isSuspended, observeInputs, reduce, sizeOf, suspend, tailOf
-
Methods inherited from class org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, 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
-
Methods inherited from interface org.reactfx.Suspendable
suspend, suspendWhen, suspendWhile, suspendWhile
-
Methods inherited from interface org.reactfx.SuspendableEventStream
suspendedWhen
-
-
-
-
Constructor Detail
-
SuspendableEventStreamBase
protected SuspendableEventStreamBase(EventStream<T> source, NotificationAccumulator<java.util.function.Consumer<? super T>,T,A> pn)
-
-