default 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>> |
CompletionStageStream.await(java.util.concurrent.Executor clientThreadExecutor) |
|
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<java.util.concurrent.CompletionStage<T>> source,
java.util.concurrent.Executor clientThreadExecutor) |
|
static <T> AwaitingEventStream<Try<T>> |
AwaitLatest.awaitCompletionStage(EventStream<java.util.concurrent.CompletionStage<T>> source,
java.util.concurrent.Executor clientThreadExecutor) |
|
static <T> AwaitingEventStream<Try<T>> |
AwaitLatest.awaitCompletionStage(EventStream<java.util.concurrent.CompletionStage<T>> source,
EventStream<?> cancelImpulse,
java.util.concurrent.Executor clientThreadExecutor) |
|
default AwaitingEventStream<Try<T>> |
CompletionStageStream.awaitLatest() |
Similar to CompletionStageStream.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(java.util.concurrent.Executor clientThreadExecutor) |
|
default AwaitingEventStream<Try<T>> |
CompletionStageStream.awaitLatest(EventStream<?> canceller) |
Similar to CompletionStageStream.awaitLatest() , with one addition:
When an event is emitted from canceller , 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,
java.util.concurrent.Executor clientThreadExecutor) |
|
default AwaitingEventStream<Try<T>> |
TaskStream.awaitLatest() |
Similar to TaskStream.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 to TaskStream.awaitLatest() , with one addition:
When an event is emitted from canceller , 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(java.util.function.BinaryOperator<T> reduction,
java.time.Duration timeout) |
Returns an event stream that accumulates events emitted from this event
stream in close temporal succession.
|
default AwaitingEventStream<T> |
EventStream.reduceSuccessions(java.util.function.BinaryOperator<T> reduction,
java.time.Duration timeout,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default <U> AwaitingEventStream<U> |
EventStream.reduceSuccessions(java.util.function.Function<? super T,? extends U> initialTransformation,
java.util.function.BiFunction<? super U,? super T,? extends U> reduction,
java.time.Duration timeout) |
|
default <U> AwaitingEventStream<U> |
EventStream.reduceSuccessions(java.util.function.Function<? super T,? extends U> initialTransformation,
java.util.function.BiFunction<? super U,? super T,? extends U> reduction,
java.time.Duration timeout,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default <U> AwaitingEventStream<U> |
EventStream.reduceSuccessions(java.util.function.Supplier<? extends U> unitSupplier,
java.util.function.BiFunction<? super U,? super T,? extends U> reduction,
java.time.Duration timeout) |
A convenient method that can be used when it is more convenient to
supply an identity of the type U than to transform an event
of type T to an event of type U .
|
default <U> AwaitingEventStream<U> |
EventStream.reduceSuccessions(java.util.function.Supplier<? extends U> unitSupplier,
java.util.function.BiFunction<? super U,? super T,? extends U> reduction,
java.time.Duration timeout,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default AwaitingEventStream<T> |
EventStream.successionEnds(java.time.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(java.time.Duration timeout,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default <A> AwaitingEventStream<T> |
EventStream.thenAccumulateFor(java.time.Duration duration,
java.util.function.Function<? super T,? extends A> initialTransformation,
java.util.function.BiFunction<? super A,? super T,? extends A> reduction,
java.util.function.Function<? super A,java.util.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
using initialTransformation .
|
default <A> AwaitingEventStream<T> |
EventStream.thenAccumulateFor(java.time.Duration duration,
java.util.function.Function<? super T,? extends A> initialTransformation,
java.util.function.BiFunction<? super A,? super T,? extends A> reduction,
java.util.function.Function<? super A,java.util.List<T>> deconstruction,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default <A> AwaitingEventStream<T> |
EventStream.thenAccumulateFor(java.time.Duration duration,
java.util.function.Supplier<? extends A> unit,
java.util.function.BiFunction<? super A,? super T,? extends A> reduction,
java.util.function.Function<? super A,java.util.List<T>> deconstruction) |
|
default <A> AwaitingEventStream<T> |
EventStream.thenAccumulateFor(java.time.Duration duration,
java.util.function.Supplier<? extends A> unit,
java.util.function.BiFunction<? super A,? super T,? extends A> reduction,
java.util.function.Function<? super A,java.util.List<T>> deconstruction,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default AwaitingEventStream<T> |
EventStream.thenIgnoreFor(java.time.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(java.time.Duration duration,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default AwaitingEventStream<T> |
EventStream.thenReduceFor(java.time.Duration duration,
java.util.function.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(java.time.Duration duration,
java.util.function.BinaryOperator<T> reduction,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|
default AwaitingEventStream<T> |
EventStream.thenRetainLatestFor(java.time.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(java.time.Duration duration,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.concurrent.Executor eventThreadExecutor) |
|