Top Fields Constructors Methods
org.reactfx

pack-priv Class AwaitLatest<T, F>

Located in compilation unit of org.reactfx.Await.

extends EventStreamBase<Try<T>>
implements AwaitingEventStream<Try<T>>
Class Inheritance
All Implemented Interfaces
org.reactfx.AwaitingEventStream, org.reactfx.EventStream, org.reactfx.Observable

Field Summary

Modifier and TypeField and Description
private final BiConsumer<F, TriConsumer<T, Throwable, Boolean>>
addCompletionHandler

private final EventStream<?>
cancelImpulse

private final Consumer<F>
canceller

private F
expectedFuture

private BooleanBinding
pending

private long
revision

private final EventStream<F>
source

Constructor Summary

AccessConstructor and Description
private
AwaitLatest(EventStream<F> source, EventStream<?> cancelImpulse, Consumer<F> canceller, BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler)

Method Summary

Modifier and TypeMethod and Description
public static <T> AwaitingEventStream<Try<T>>
awaitCompletionStage(EventStream<CompletionStage<T>> source, Executor clientThreadExecutor)

public static <T> AwaitingEventStream<Try<T>>
awaitCompletionStage(EventStream<CompletionStage<T>> source, EventStream<?> cancelImpulse, Executor clientThreadExecutor)

public static <T> AwaitingEventStream<Try<T>>
awaitTask(EventStream<Task<T>> source)

public static <T> AwaitingEventStream<Try<T>>
awaitTask(EventStream<Task<T>> source, EventStream<?> cancelImpulse)

public boolean
isPending()

Implements org.reactfx.AwaitingEventStream.isPending.

protected 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 final long
replaceExpected(F newExpected)

private void
setExpected(F newExpected)

Field Detail

addCompletionHandlerback to summary
private final BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler
cancelImpulseback to summary
private final EventStream<?> cancelImpulse
cancellerback to summary
private final Consumer<F> canceller
expectedFutureback to summary
private F expectedFuture
pendingback to summary
private BooleanBinding pending
revisionback to summary
private long revision
sourceback to summary
private final EventStream<F> source

Constructor Detail

AwaitLatestback to summary
private AwaitLatest(EventStream<F> source, EventStream<?> cancelImpulse, Consumer<F> canceller, BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler)

Method Detail

awaitCompletionStageback to summary
public static <T> AwaitingEventStream<Try<T>> awaitCompletionStage(EventStream<CompletionStage<T>> source, Executor clientThreadExecutor)
awaitCompletionStageback to summary
public static <T> AwaitingEventStream<Try<T>> awaitCompletionStage(EventStream<CompletionStage<T>> source, EventStream<?> cancelImpulse, Executor clientThreadExecutor)
awaitTaskback to summary
public static <T> AwaitingEventStream<Try<T>> awaitTask(EventStream<Task<T>> source)
awaitTaskback to summary
public static <T> AwaitingEventStream<Try<T>> awaitTask(EventStream<Task<T>> source, EventStream<?> cancelImpulse)
isPendingback to summary
public boolean isPending()

Implements org.reactfx.AwaitingEventStream.isPending.

Annotations
@Override
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
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
replaceExpectedback to summary
private final long replaceExpected(F newExpected)
setExpectedback to summary
private void setExpected(F newExpected)