Package org.reactfx

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 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 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>