Class SuppressibleEventStream<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.SuppressibleEventStream<T>

All Implemented Interfaces:

EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<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

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 SuspendableBase

isSuspended, observeInputs, suspend

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface 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 Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Methods inherited from interface Suspendable

suspend, suspendWhen, suspendWhile, suspendWhile

Methods inherited from interface SuspendableEventStream

suspendedWhen

Constructor Details

SuppressibleEventStream

SuppressibleEventStream(EventStream<T> source)

Method Details

sizeOf

protected AccumulatorSize sizeOf(T accum)

Specified by:

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

headOf

protected T headOf(T accum)

Specified by:

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

tailOf

protected T tailOf(T accum)

Specified by:

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

initialAccumulator

protected T initialAccumulator(T value)

Overrides:

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

reduce

protected T reduce(T accum,
 T value)

Overrides:

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