Top Description Fields Constructors Methods
org.reactfx

pack-priv Class AccumulatingStream<T, U>

extends EventStreamBase<U>
Class Inheritance
Imports
java.util.function.BiFunction, .Function
See EventStream#accumulate(BiFunction, Function)

Field Summary

Modifier and TypeField and Description
private U
event

private boolean
hasEvent

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

private final EventStream<T>
input

private final BiFunction<? super U, ? super T, ? extends U>
reduction

Constructor Summary

AccessConstructor and Description
public
AccumulatingStream(EventStream<T> input, Function<? super T, ? extends U> initial, BiFunction<? super U, ? super T, ? extends U> reduction)

Method Summary

Modifier and TypeMethod and Description
protected final Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

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

Field Detail

eventback to summary
private U event
hasEventback to summary
private boolean hasEvent
initialTransformationback to summary
private final Function<? super T, ? extends U> initialTransformation
inputback to summary
private final EventStream<T> input
reductionback to summary
private final BiFunction<? super U, ? super T, ? extends U> reduction

Constructor Detail

AccumulatingStreamback to summary
public AccumulatingStream(EventStream<T> input, Function<? super T, ? extends U> initial, BiFunction<? super U, ? super T, ? extends U> reduction)

Method Detail

observeInputsback to summary
protected final 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