SuppressibleEventStream

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 class SuspendableBase<java.util.function.Consumer<? super T>,T,T>
  - headOf
```
protected T headOf(T accum)
```
    Specified by:
    
    headOf in class SuspendableBase<java.util.function.Consumer<? super T>,T,T>
  - tailOf
```
protected T tailOf(T accum)
```
    Specified by:
    
    tailOf in class SuspendableBase<java.util.function.Consumer<? super T>,T,T>
  - initialAccumulator
```
protected T initialAccumulator(T value)
```
    Overrides:
    
    initialAccumulator in class SuspendableBase<java.util.function.Consumer<? super T>,T,T>
  - reduce
```
protected T reduce(T accum,
                   T value)
```
    Overrides:
    
    reduce in class SuspendableBase<java.util.function.Consumer<? super T>,T,T>