Package org.reactfx

Class AbstractReducibleEventStream<T>

java.lang.Object

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

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

org.reactfx.SuspendableEventStreamBase<T,T>

org.reactfx.AbstractReducibleEventStream<T>

All Implemented Interfaces:

EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<Consumer<? super T>,T>, Suspendable, SuspendableEventStream<T>

Direct Known Subclasses:

ForgetfulEventStream, ReducibleEventStream

abstract class AbstractReducibleEventStream<T>
extends SuspendableEventStreamBase<T,T>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReducibleEventStream(EventStream<T> source, NotificationAccumulator<Consumer<? super T>,T,T> pn)

Method Summary

Modifier and Type	Method	Description
protected final T	headOf(T accum)
protected final AccumulatorSize	sizeOf(T accum)
protected final T	tailOf(T accum)

Methods inherited from class org.reactfx.SuspendableBase

initialAccumulator, isSuspended, observeInputs, reduce, suspend

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

AbstractReducibleEventStream

protected AbstractReducibleEventStream(EventStream<T> source,
 NotificationAccumulator<Consumer<? super T>,T,T> pn)

Method Details

sizeOf

protected final AccumulatorSize sizeOf(T accum)

Specified by:

sizeOf in class SuspendableBase<Consumer<? super T>,T,T>

headOf

protected final T headOf(T accum)

Specified by:

headOf in class SuspendableBase<Consumer<? super T>,T,T>

tailOf

protected final T tailOf(T accum)

Specified by:

tailOf in class SuspendableBase<Consumer<? super T>,T,T>