Top Fields Constructors Methods
org.reactfx

pack-priv Class Await<T, F>

Additional top-level class in compilation unit: AwaitLatest.

extends EventStreamBase<Try<T>>
implements AwaitingEventStream<Try<T>>
Class Inheritance
All Implemented Interfaces
org.reactfx.AwaitingEventStream, org.reactfx.EventStream, org.reactfx.Observable
Static Imports
javafx.concurrent.WorkerStateEvent.*

Field Summary

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

private final SuspendableNo
pending

private final EventStream<F>
source

Constructor Summary

AccessConstructor and Description
private
Await(EventStream<F> source, BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler)

Method Summary

Modifier and TypeMethod and Description
pack-priv static <T> void
addCompletionHandler(CompletionStage<T> future, TriConsumer<T, Throwable, Boolean> handler, Executor executor)

pack-priv static <T> void
addCompletionHandler(Task<T> t, TriConsumer<T, Throwable, Boolean> handler)

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

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

public final 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 final 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

addCompletionHandlerback to summary
private final BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler
pendingback to summary
private final SuspendableNo pending
sourceback to summary
private final EventStream<F> source

Constructor Detail

Awaitback to summary
private Await(EventStream<F> source, BiConsumer<F, TriConsumer<T, Throwable, Boolean>> addCompletionHandler)

Method Detail

addCompletionHandlerback to summary
pack-priv static <T> void addCompletionHandler(CompletionStage<T> future, TriConsumer<T, Throwable, Boolean> handler, Executor executor)
addCompletionHandlerback to summary
pack-priv static <T> void addCompletionHandler(Task<T> t, TriConsumer<T, Throwable, Boolean> handler)
awaitCompletionStageback to summary
public static <T> AwaitingEventStream<Try<T>> awaitCompletionStage(EventStream<CompletionStage<T>> source, Executor clientThreadExecutor)
awaitTaskback to summary
public static <T> AwaitingEventStream<Try<T>> awaitTask(EventStream<Task<T>> source)
isPendingback to summary
public final 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 final 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