Package org.reactfx
Class SuppressibleEventStream<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.SuppressibleEventStream<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>
final class SuppressibleEventStream<T> extends SuspendableEventStreamBase<T,T>
-
-
Constructor Summary
Constructors Constructor Description SuppressibleEventStream(EventStream<T> source)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected T
headOf(T accum)
protected T
initialAccumulator(T value)
protected T
reduce(T accum, T value)
protected AccumulatorSize
sizeOf(T accum)
protected T
tailOf(T accum)
-
Methods inherited from class org.reactfx.SuspendableBase
isSuspended, observeInputs, 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
-
SuppressibleEventStream
SuppressibleEventStream(EventStream<T> source)
-
-
Method Detail
-
sizeOf
protected AccumulatorSize sizeOf(T accum)
- Specified by:
sizeOf
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
headOf
protected T headOf(T accum)
- Specified by:
headOf
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
tailOf
protected T tailOf(T accum)
- Specified by:
tailOf
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
initialAccumulator
protected T initialAccumulator(T value)
- Overrides:
initialAccumulator
in classSuspendableBase<java.util.function.Consumer<? super T>,T,T>
-
-