Top Fields Constructors Methods
org.reactfx

pack-priv Class AccumulateBetweenStream<T, A>

extends EventStreamBase<T>
Class Inheritance
Imports
java.util.List, 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 boolean
hasValue

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

private final EventStream<T>
source

private final EventStream<?>
ticks

Constructor Summary

AccessConstructor and Description
public
AccumulateBetweenStream(EventStream<T> source, EventStream<?> ticks, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, List<T>> deconstruction)

Method Summary

Modifier and TypeMethod and Description
private void
handleEvent(T event)

private void
handleTick(Object tick)

protected Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

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

private void
reset()

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
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
ticksback to summary
private final EventStream<?> ticks

Constructor Detail

AccumulateBetweenStreamback to summary
public AccumulateBetweenStream(EventStream<T> source, EventStream<?> ticks, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, List<T>> deconstruction)

Method Detail

handleEventback to summary
private void handleEvent(T event)
handleTickback to summary
private void handleTick(Object tick)
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
resetback to summary
private void reset()