Class AccumulativeEventStream<T,A>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super T>, T>

org.reactfx.SuspendableBase<Consumer<? super T>, T, A>

org.reactfx.SuspendableEventStreamBase<T,A>

org.reactfx.AccumulativeEventStream<T,A>

All Implemented Interfaces:

EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<Consumer<? super T>, T>, Suspendable, SuspendableEventStream<T>

final class AccumulativeEventStream<T,A>
extends SuspendableEventStreamBase<T,A>

Field Summary

Fields

Modifier and Type	Field	Description
private final Function<? super A, ? extends T>	head
private final Function<? super A, AccumulatorSize>	size
private final Function<? super A, ? extends A>	tail

Constructor Summary

Constructors

Constructor	Description
AccumulativeEventStream(EventStream<T> source, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, AccumulatorSize> size, Function<? super A, ? extends T> head, Function<? super A, ? extends A> tail)

Method Summary

Modifier and Type	Method	Description
protected T	headOf(A accum)
protected AccumulatorSize	sizeOf(A accum)
protected A	tailOf(A accum)

Methods inherited from class SuspendableBase

initialAccumulator, isSuspended, observeInputs, reduce, 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

Field Details

size

private final Function<? super A, AccumulatorSize> size

head

private final Function<? super A, ? extends T> head

tail

private final Function<? super A, ? extends A> tail

Constructor Details

AccumulativeEventStream

AccumulativeEventStream(EventStream<T> source,
 Function<? super T, ? extends A> initialTransformation,
 BiFunction<? super A, ? super T, ? extends A> accumulation,
 Function<? super A, AccumulatorSize> size,
 Function<? super A, ? extends T> head,
 Function<? super A, ? extends A> tail)

Method Details

sizeOf

protected AccumulatorSize sizeOf(A accum)

Specified by:

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

headOf

protected T headOf(A accum)

Specified by:

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

tailOf

protected A tailOf(A accum)

Specified by:

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