Top Inners Fields Constructors Methods
org.reactfx

pack-priv Class ThenAccumulateForStream<T, A>

extends EventStreamBase<T>
implements AwaitingEventStream<T>
Class Inheritance
All Implemented Interfaces
org.reactfx.AwaitingEventStream, org.reactfx.EventStream, org.reactfx.Observable
Imports
java.util.Collections, .List, java.util.function.BiFunction, .Function, javafx.beans.binding.BooleanBinding, javafx.beans.value.ObservableBooleanValue, org.reactfx.util.Timer

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static enum
ThenAccumulateForStream.State

Field Summary

Modifier and TypeField and Description
private A
acc

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

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

private final EventStream<T>
input

private BooleanBinding
pending

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

private ThenAccumulateForStream.State
state

private final Timer
timer

Constructor Summary

AccessConstructor and Description
public
ThenAccumulateForStream(EventStream<T> input, Function<? super T, ? extends A> initial, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction, Function<Runnable, Timer> timerFactory)

Method Summary

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

private void
handleTimeout()

private void
invalidatePending()

public boolean
isPending()

Implements org.reactfx.AwaitingEventStream.isPending.

protected final Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

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

public ObservableBooleanValue
pendingProperty()

Implements org.reactfx.AwaitingEventStream.pendingProperty.

Indicates whether there is a pending event that will be emitted by this stream in the (near) future.

private void
setState(ThenAccumulateForStream.State state)

Field Detail

accback to summary
private A acc
deconstructionback to summary
private final Function<? super A, List<T>> deconstruction
initialback to summary
private final Function<? super T, ? extends A> initial
inputback to summary
private final EventStream<T> input
pendingback to summary
private BooleanBinding pending
reductionback to summary
private final BiFunction<? super A, ? super T, ? extends A> reduction
stateback to summary
private ThenAccumulateForStream.State state
timerback to summary
private final Timer timer

Constructor Detail

ThenAccumulateForStreamback to summary
public ThenAccumulateForStream(EventStream<T> input, Function<? super T, ? extends A> initial, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction, Function<Runnable, Timer> timerFactory)

Method Detail

handleEventback to summary
private void handleEvent(T t)
handleTimeoutback to summary
private void handleTimeout()
invalidatePendingback to summary
private void invalidatePending()
isPendingback to summary
public boolean isPending()

Implements org.reactfx.AwaitingEventStream.isPending.

Annotations
@Override
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
pendingPropertyback to summary
public ObservableBooleanValue pendingProperty()

Implements org.reactfx.AwaitingEventStream.pendingProperty.

Doc from org.reactfx.AwaitingEventStream.pendingProperty.

Indicates whether there is a pending event that will be emitted by this stream in the (near) future. This may mean that an event has occurred that causes this stream to emit an event with some delay, e.g. waiting for a timer or completion of an asynchronous task.

Annotations
@Override
setStateback to summary
private void setState(ThenAccumulateForStream.State state)
org.reactfx back to summary

private final Enum ThenAccumulateForStream.State

extends Enum<ThenAccumulateForStream.State>
Class Inheritance

Field Summary

Modifier and TypeField and Description
public static final ThenAccumulateForStream.State
ACC_HAS_EVENT

public static final ThenAccumulateForStream.State
ACC_NO_EVENT

public static final ThenAccumulateForStream.State
READY

Constructor Summary

AccessConstructor and Description
private
State()

Method Summary

Modifier and TypeMethod and Description
public static ThenAccumulateForStream.State
valueOf(String name)

public static ThenAccumulateForStream.State[]
values()

Inherited from java.lang.Enum:
clonecompareTodescribeConstableequalsfinalizegetDeclaringClasshashCodenameordinaltoStringvalueOf

Field Detail

ACC_HAS_EVENTback to summary
public static final ThenAccumulateForStream.State ACC_HAS_EVENT
ACC_NO_EVENTback to summary
public static final ThenAccumulateForStream.State ACC_NO_EVENT
READYback to summary
public static final ThenAccumulateForStream.State READY

Constructor Detail

Stateback to summary
private State()

Method Detail

valueOfback to summary
public static ThenAccumulateForStream.State valueOf(String name)
valuesback to summary
public static ThenAccumulateForStream.State[] values()