Package org.reactfx
Class SuspendableEventStreamBase<T,A>
java.lang.Object
- All Implemented Interfaces:
EventStream<T>
,Observable<Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<Consumer<? super T>,
,T> Suspendable
,SuspendableEventStream<T>
- Direct Known Subclasses:
AbstractReducibleEventStream
,AccumulativeEventStream
,PausableEventStream
,SuppressibleEventStream
abstract class SuspendableEventStreamBase<T,A>
extends SuspendableBase<Consumer<? super T>,T,A>
implements ProperEventStream<T>, SuspendableEventStream<T>
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
SuspendableEventStreamBase
(EventStream<T> source, NotificationAccumulator<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 Details
-
SuspendableEventStreamBase
protected SuspendableEventStreamBase(EventStream<T> source, NotificationAccumulator<Consumer<? super T>, T, A> pn)
-