Uses of Interface
org.reactfx.AwaitingEventStream
Packages that use AwaitingEventStream
-
Uses of AwaitingEventStream in org.reactfx
Classes in org.reactfx that implement AwaitingEventStreamModifier and TypeClassDescription(package private) class
Await<T,
F> (package private) class
AwaitLatest<T,
F> (package private) class
(package private) class
Methods in org.reactfx that return AwaitingEventStreamModifier and TypeMethodDescriptiondefault AwaitingEventStream
<Try<T>> CompletionStageStream.await()
Returns a new stream that emits the results of completions stages emitted from this stream when they become available.default AwaitingEventStream
<Try<T>> A variant ofCompletionStageStream.await()
for streams that do not live on the JavaFX application thread.default AwaitingEventStream
<Try<T>> TaskStream.await()
Returns a new stream that emits the results of tasks emitted from this stream when they become available.static <T> AwaitingEventStream
<Try<T>> Await.awaitCompletionStage
(EventStream<CompletionStage<T>> source, Executor clientThreadExecutor) static <T> AwaitingEventStream
<Try<T>> AwaitLatest.awaitCompletionStage
(EventStream<CompletionStage<T>> source, Executor clientThreadExecutor) static <T> AwaitingEventStream
<Try<T>> AwaitLatest.awaitCompletionStage
(EventStream<CompletionStage<T>> source, EventStream<?> cancelImpulse, Executor clientThreadExecutor) default AwaitingEventStream
<Try<T>> CompletionStageStream.awaitLatest()
Similar toCompletionStageStream.await()
, with one difference: for completion stages s1 and s2 emitted from this stream in this order, if s2 arrives before s1 is completed, then the result of s1 is discarded (i.e.default AwaitingEventStream
<Try<T>> CompletionStageStream.awaitLatest
(Executor clientThreadExecutor) A variant ofCompletionStageStream.awaitLatest()
for streams that do not live on the JavaFX application thread.default AwaitingEventStream
<Try<T>> CompletionStageStream.awaitLatest
(EventStream<?> canceller) Similar toCompletionStageStream.awaitLatest()
, with one addition: When an event is emitted fromcanceller
, if the completion stage most recently emitted from this stream has not yet completed, its result is discarded (i.e.default AwaitingEventStream
<Try<T>> CompletionStageStream.awaitLatest
(EventStream<?> canceller, Executor clientThreadExecutor) A variant ofCompletionStageStream.awaitLatest(EventStream)
for streams that do not live on the JavaFX application thread.default AwaitingEventStream
<Try<T>> TaskStream.awaitLatest()
Similar toTaskStream.await()
, with one difference: for tasks t1 and t2 emitted from this stream in this order, if t2 arrives before t1 is completed, then t1 is cancelled and its result is discarded (i.e.default AwaitingEventStream
<Try<T>> TaskStream.awaitLatest
(EventStream<?> canceller) Similar toTaskStream.awaitLatest()
, with one addition: When an event is emitted fromcanceller
, if the task most recently emitted from this stream has not yet completed, it is cancelled and its result discarded (i.e.static <T> AwaitingEventStream
<Try<T>> Await.awaitTask
(EventStream<javafx.concurrent.Task<T>> source) static <T> AwaitingEventStream
<Try<T>> AwaitLatest.awaitTask
(EventStream<javafx.concurrent.Task<T>> source) static <T> AwaitingEventStream
<Try<T>> AwaitLatest.awaitTask
(EventStream<javafx.concurrent.Task<T>> source, EventStream<?> cancelImpulse) default AwaitingEventStream
<T> EventStream.reduceSuccessions
(BinaryOperator<T> reduction, Duration timeout) Returns an event stream that accumulates events emitted from this event stream in close temporal succession.default AwaitingEventStream
<T> EventStream.reduceSuccessions
(BinaryOperator<T> reduction, Duration timeout, ScheduledExecutorService scheduler, Executor eventThreadExecutor) An analog toEventStream.reduceSuccessions(BinaryOperator, Duration)
to use outside of JavaFX application thread.default <U> AwaitingEventStream
<U> EventStream.reduceSuccessions
(Function<? super T, ? extends U> initialTransformation, BiFunction<? super U, ? super T, ? extends U> reduction, Duration timeout) A more general version ofEventStream.reduceSuccessions(BinaryOperator, Duration)
that allows the accumulated event to be of different type.default <U> AwaitingEventStream
<U> EventStream.reduceSuccessions
(Function<? super T, ? extends U> initialTransformation, BiFunction<? super U, ? super T, ? extends U> reduction, Duration timeout, ScheduledExecutorService scheduler, Executor eventThreadExecutor) An analog toEventStream.reduceSuccessions(Function, BiFunction, Duration)
to use outside of JavaFX application thread.default <U> AwaitingEventStream
<U> EventStream.reduceSuccessions
(Supplier<? extends U> unitSupplier, BiFunction<? super U, ? super T, ? extends U> reduction, Duration timeout) A convenient method that can be used when it is more convenient to supply an identity of the typeU
than to transform an event of typeT
to an event of typeU
.default <U> AwaitingEventStream
<U> EventStream.reduceSuccessions
(Supplier<? extends U> unitSupplier, BiFunction<? super U, ? super T, ? extends U> reduction, Duration timeout, ScheduledExecutorService scheduler, Executor eventThreadExecutor) An analog toEventStream.reduceSuccessions(Supplier, BiFunction, Duration)
to use outside of JavaFX application thread.default AwaitingEventStream
<T> EventStream.successionEnds
(Duration timeout) Returns an event stream that, when events are emitted from this stream in close temporal succession, emits only the last event of the succession.default AwaitingEventStream
<T> EventStream.successionEnds
(Duration timeout, ScheduledExecutorService scheduler, Executor eventThreadExecutor) An analog toEventStream.successionEnds(Duration)
to use outside of JavaFX application thread.default <A> AwaitingEventStream
<T> EventStream.thenAccumulateFor
(Duration duration, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction) Returns an event stream that emits the first event emitted from this stream and then, if the next event arrives within the given duration since the last emitted event, it is converted to an accumulator value usinginitialTransformation
.default <A> AwaitingEventStream
<T> EventStream.thenAccumulateFor
(Duration duration, Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction, ScheduledExecutorService scheduler, Executor eventThreadExecutor) default <A> AwaitingEventStream
<T> EventStream.thenAccumulateFor
(Duration duration, Supplier<? extends A> unit, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction) A variant ofEventStream.thenAccumulateFor(Duration, Function, BiFunction, Function)
for cases when it is more convenient to provide a unit element for accumulation than the initial transformation.default <A> AwaitingEventStream
<T> EventStream.thenAccumulateFor
(Duration duration, Supplier<? extends A> unit, BiFunction<? super A, ? super T, ? extends A> reduction, Function<? super A, List<T>> deconstruction, ScheduledExecutorService scheduler, Executor eventThreadExecutor) default AwaitingEventStream
<T> EventStream.thenIgnoreFor
(Duration duration) Returns an event stream that emits the first event emitted from this stream and then ignores the following events for the given duration.default AwaitingEventStream
<T> EventStream.thenIgnoreFor
(Duration duration, ScheduledExecutorService scheduler, Executor eventThreadExecutor) default AwaitingEventStream
<T> EventStream.thenReduceFor
(Duration duration, BinaryOperator<T> reduction) Returns an event stream that emits the first event emitted from this stream and then reduces all following events that arrive within the given duration into a single event using the given reduction function.default AwaitingEventStream
<T> EventStream.thenReduceFor
(Duration duration, BinaryOperator<T> reduction, ScheduledExecutorService scheduler, Executor eventThreadExecutor) default AwaitingEventStream
<T> EventStream.thenRetainLatestFor
(Duration duration) Returns an event stream that emits the first event emitted from this stream and then remembers, but does not emit, the latest event emitted from this stream.default AwaitingEventStream
<T> EventStream.thenRetainLatestFor
(Duration duration, ScheduledExecutorService scheduler, Executor eventThreadExecutor)