Top Fields Constructors Methods
org.reactfx

pack-priv Class AccumulateUntilLaterStream<T, A>

extends EventStreamBase<T>
Class Inheritance
Imports
java.util.List, java.util.concurrent.Executor, java.util.function.BiFunction, .Function

Field Summary

Modifier and TypeField and 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

AccessConstructor and Description
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 Summary

Modifier and TypeMethod and Description
private void
emitAccum()

private void
handleEvent(T event)

protected Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any.

Field Detail

accumback to summary
private A accum
accumulationback to summary
private final BiFunction<? super A, ? super T, ? extends A> accumulation
deconstructionback to summary
private final Function<? super A, List<T>> deconstruction
eventThreadExecutorback to summary
private final Executor eventThreadExecutor
hasValueback to summary
private boolean hasValue
initialTransformationback to summary
private final Function<? super T, ? extends A> initialTransformation
sourceback to summary
private final EventStream<T> source

Constructor Detail

AccumulateUntilLaterStreamback to summary
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 Detail

emitAccumback to summary
private void emitAccum()
handleEventback to summary
private void handleEvent(T event)
observeInputsback to summary
protected Subscription observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Doc from org.reactfx.ObservableBase.observeInputs.

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 newObserver(Object) is called for the first observer.

Annotations
@Override