Package org.reactfx

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 org.reactfx.SuspendableBase

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

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>