Package org.reactfx

Class SuspendableEventStreamBase<T,A>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super T>,T>

org.reactfx.SuspendableBase<Consumer<? super T>,T,A>

org.reactfx.SuspendableEventStreamBase<T,A>

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

Constructors

Modifier	Constructor	Description
protected	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)