Package org.reactfx

Class AccumulateBetweenStream<T,A>

java.lang.Object

org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>

org.reactfx.EventStreamBase<T>

org.reactfx.AccumulateBetweenStream<T,A>

All Implemented Interfaces:

EventStream<T>, Observable<java.util.function.Consumer<? super T>>, ProperEventStream<T>, ProperObservable<java.util.function.Consumer<? super T>,T>

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

Field Summary

Fields

Modifier and Type	Field	Description
private A	accum
private java.util.function.BiFunction<? super A,? super T,? extends A>	accumulation
private java.util.function.Function<? super A,java.util.List<T>>	deconstruction
private boolean	hasValue
private java.util.function.Function<? super T,? extends A>	initialTransformation
private EventStream<T>	source
private EventStream<?>	ticks

Constructor Summary

Constructors

Constructor	Description
AccumulateBetweenStream(EventStream<T> source, EventStream<?> ticks, java.util.function.Function<? super T,? extends A> initialTransformation, java.util.function.BiFunction<? super A,? super T,? extends A> accumulation, java.util.function.Function<? super A,java.util.List<T>> deconstruction)

Method Summary

Modifier and Type	Method	Description
private void	handleEvent(T event)
private void	handleTick(java.lang.Object tick)
protected Subscription	observeInputs()	Starts observing this observable's input(s), if any.
private void	reset()

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

Field Detail

source

private final EventStream<T> source

ticks

private final EventStream<?> ticks

initialTransformation

private final java.util.function.Function<? super T,? extends A> initialTransformation

accumulation

private final java.util.function.BiFunction<? super A,? super T,? extends A> accumulation

deconstruction

private final java.util.function.Function<? super A,java.util.List<T>> deconstruction

hasValue

private boolean hasValue

accum

private A accum

Constructor Detail

AccumulateBetweenStream

public AccumulateBetweenStream(EventStream<T> source,
                               EventStream<?> ticks,
                               java.util.function.Function<? super T,? extends A> initialTransformation,
                               java.util.function.BiFunction<? super A,? super T,? extends A> accumulation,
                               java.util.function.Function<? super A,java.util.List<T>> deconstruction)

Method Detail

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<java.util.function.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)

handleTick

private void handleTick(java.lang.Object tick)

reset

private void reset()