Top Fields Constructors Methods
org.reactfx

pack-priv Class SuccessionReducingStream<I, O>

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

Field Summary

Modifier and TypeField and Description
private O
event

private boolean
hasEvent

private final Function<? super I, ? extends O>
initial

private final EventStream<I>
input

private BooleanBinding
pending

private final BiFunction<? super O, ? super I, ? extends O>
reduction

private final Timer
timer

Constructor Summary

AccessConstructor and Description
public
SuccessionReducingStream(EventStream<I> input, Function<? super I, ? extends O> initial, BiFunction<? super O, ? super I, ? extends O> reduction, Function<Runnable, Timer> timerFactory)

Method Summary

Modifier and TypeMethod and Description
private void
handleEvent(I i)

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.

Field Detail

eventback to summary
private O event
hasEventback to summary
private boolean hasEvent
initialback to summary
private final Function<? super I, ? extends O> initial
inputback to summary
private final EventStream<I> input
pendingback to summary
private BooleanBinding pending
reductionback to summary
private final BiFunction<? super O, ? super I, ? extends O> reduction
timerback to summary
private final Timer timer

Constructor Detail

SuccessionReducingStreamback to summary
public SuccessionReducingStream(EventStream<I> input, Function<? super I, ? extends O> initial, BiFunction<? super O, ? super I, ? extends O> reduction, Function<Runnable, Timer> timerFactory)

Method Detail

handleEventback to summary
private void handleEvent(I i)
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