Package org.reactfx
Class AbstractReducibleEventStream<T>
- java.lang.Object
-
- org.reactfx.ObservableBase<O,T>
-
- org.reactfx.SuspendableBase<java.util.function.Consumer<? super T>,T,A>
-
- org.reactfx.SuspendableEventStreamBase<T,T>
-
- org.reactfx.AbstractReducibleEventStream<T>
-
- 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:
ForgetfulEventStream
,ReducibleEventStream
abstract class AbstractReducibleEventStream<T> extends SuspendableEventStreamBase<T,T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractReducibleEventStream(EventStream<T> source, NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> pn)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected T
headOf(T accum)
protected AccumulatorSize
sizeOf(T accum)
protected 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 Detail
-
AbstractReducibleEventStream
protected AbstractReducibleEventStream(EventStream<T> source, NotificationAccumulator<java.util.function.Consumer<? super T>,T,T> pn)
-
-
Method Detail
-
sizeOf
protected final AccumulatorSize sizeOf(T accum)
- Specified by:
sizeOf
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
headOf
protected final T headOf(T accum)
- Specified by:
headOf
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
-