Class AccumulateUntilLaterStream<T,A>

java.lang.Object

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

org.reactfx.EventStreamBase<T>

org.reactfx.AccumulateUntilLaterStream<T,A>

All Implemented Interfaces:

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

class AccumulateUntilLaterStream<T,A>
extends EventStreamBase<T>

Field Summary

Fields

Modifier and Type	Field	Description
private A	accum
private final BiFunction<? super A, ? super T, ? extends A>	accumulation
private final Function<? super A, List<T>>	deconstruction
private final Executor	eventThreadExecutor
private boolean	hasValue
private final Function<? super T, ? extends A>	initialTransformation
private final EventStream<T>	source

Constructor Summary

Constructors

Constructor	Description
AccumulateUntilLaterStream(EventStream<T> source, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, List<T>> deconstruction, Executor eventThreadExecutor)

Method Summary

Modifier and Type	Method	Description
private void	emitAccum()
private void	handleEvent(T event)
protected Subscription	observeInputs()	Starts observing this observable's input(s), if any.

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

Field Details

source

private final EventStream<T> source

initialTransformation

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

accumulation

private final BiFunction<? super A, ? super T, ? extends A> accumulation

deconstruction

private final Function<? super A, List<T>> deconstruction

eventThreadExecutor

private final Executor eventThreadExecutor

hasValue

private boolean hasValue

accum

private A accum

Constructor Details

AccumulateUntilLaterStream

public AccumulateUntilLaterStream(EventStream<T> source,
 Function<? super T, ? extends A> initialTransformation,
 BiFunction<? super A, ? super T, ? extends A> accumulation,
 Function<? super A, List<T>> deconstruction,
 Executor eventThreadExecutor)

Method Details

observeInputs

protected Subscription observeInputs()

Description copied from class: ObservableBase

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before ObservableBase.newObserver(Object) is called for the first observer.

Specified by:

observeInputs in class ObservableBase<Consumer<? super T>, T>

Returns:

subscription used to stop observing inputs. The subscription is unsubscribed (i.e. input observation stops) when the number of observers goes down to 0.

handleEvent

private void handleEvent(T event)

emitAccum

private void emitAccum()