Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class CompletionAwaitable<T>

java.lang.Object

io.helidon.common.reactive.CompletionAwaitable<T>

Type Parameters:

T - payload type

All Implemented Interfaces:

Awaitable<T>, CompletionStage<T>

Direct Known Subclasses:

CompletionSingle

public class CompletionAwaitable<T>
extends Object
implements CompletionStage<T>, Awaitable<T>

CompletionStage wrapper enriched with Awaitable.

Method Summary

Modifier and Type	Method	Description
CompletionAwaitable<Void>	acceptEither(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionAwaitable<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action)
CompletionAwaitable<Void>	acceptEitherAsync(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor)
<U> CompletionAwaitable<U>	applyToEither(CompletionStage<? extends T> other, Function<? super T,U> fn)
<U> CompletionAwaitable<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn)
<U> CompletionAwaitable<U>	applyToEitherAsync(CompletionStage<? extends T> other, Function<? super T,U> fn, Executor executor)
CompletionAwaitable<T>	exceptionally(Function<Throwable,? extends T> fn)
CompletionAwaitable<T>	exceptionallyAccept(Consumer<Throwable> consumer)	Returns a new CompletionAwaitable that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied consumer.
<U> CompletionAwaitable<U>	handle(BiFunction<? super T,Throwable,? extends U> fn)
<U> CompletionAwaitable<U>	handleAsync(BiFunction<? super T,Throwable,? extends U> fn)
<U> CompletionAwaitable<U>	handleAsync(BiFunction<? super T,Throwable,? extends U> fn, Executor executor)
CompletionAwaitable<Void>	runAfterBoth(CompletionStage<?> other, Runnable action)
CompletionAwaitable<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action)
CompletionAwaitable<Void>	runAfterBothAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletionAwaitable<Void>	runAfterEither(CompletionStage<?> other, Runnable action)
CompletionAwaitable<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action)
CompletionAwaitable<Void>	runAfterEitherAsync(CompletionStage<?> other, Runnable action, Executor executor)
CompletionAwaitable<Void>	thenAccept(Consumer<? super T> action)
CompletionAwaitable<Void>	thenAcceptAsync(Consumer<? super T> action)
CompletionAwaitable<Void>	thenAcceptAsync(Consumer<? super T> action, Executor executor)
<U> CompletionAwaitable<Void>	thenAcceptBoth(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action)
<U> CompletionAwaitable<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action)
<U> CompletionAwaitable<Void>	thenAcceptBothAsync(CompletionStage<? extends U> other, BiConsumer<? super T,? super U> action, Executor executor)
<U> CompletionAwaitable<U>	thenApply(Function<? super T,? extends U> fn)
<U> CompletionAwaitable<U>	thenApplyAsync(Function<? super T,? extends U> fn)
<U> CompletionAwaitable<U>	thenApplyAsync(Function<? super T,? extends U> fn, Executor executor)
<U,V> CompletionAwaitable<V>	thenCombine(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)
<U,V> CompletionAwaitable<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)
<U,V> CompletionAwaitable<V>	thenCombineAsync(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn, Executor executor)
<U> CompletionAwaitable<U>	thenCompose(Function<? super T,? extends CompletionStage<U>> fn)
<U> CompletionAwaitable<U>	thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn)
<U> CompletionAwaitable<U>	thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn, Executor executor)
CompletionAwaitable<Void>	thenRun(Runnable action)
CompletionAwaitable<Void>	thenRunAsync(Runnable action)
CompletionAwaitable<Void>	thenRunAsync(Runnable action, Executor executor)
CompletableFuture<T>	toCompletableFuture()	Returns a CompletableFuture maintaining the same completion properties as this stage.
CompletionAwaitable<T>	whenComplete(BiConsumer<? super T,? super Throwable> action)
CompletionAwaitable<T>	whenCompleteAsync(BiConsumer<? super T,? super Throwable> action)
CompletionAwaitable<T>	whenCompleteAsync(BiConsumer<? super T,? super Throwable> action, Executor executor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.common.reactive.Awaitable

await, await, await

Method Detail

thenApply

public <U> CompletionAwaitable<U> thenApply(Function<? super T,? extends U> fn)

Specified by:

thenApply in interface CompletionStage<T>

thenApplyAsync

public <U> CompletionAwaitable<U> thenApplyAsync(Function<? super T,? extends U> fn)

Specified by:

thenApplyAsync in interface CompletionStage<T>

thenApplyAsync

public <U> CompletionAwaitable<U> thenApplyAsync(Function<? super T,? extends U> fn,
                                                 Executor executor)

Specified by:

thenApplyAsync in interface CompletionStage<T>

thenAccept

public CompletionAwaitable<Void> thenAccept(Consumer<? super T> action)

Specified by:

thenAccept in interface CompletionStage<T>

thenAcceptAsync

public CompletionAwaitable<Void> thenAcceptAsync(Consumer<? super T> action)

Specified by:

thenAcceptAsync in interface CompletionStage<T>

thenAcceptAsync

public CompletionAwaitable<Void> thenAcceptAsync(Consumer<? super T> action,
                                                 Executor executor)

Specified by:

thenAcceptAsync in interface CompletionStage<T>

thenRun

public CompletionAwaitable<Void> thenRun(Runnable action)

Specified by:

thenRun in interface CompletionStage<T>

thenRunAsync

public CompletionAwaitable<Void> thenRunAsync(Runnable action)

Specified by:

thenRunAsync in interface CompletionStage<T>

thenRunAsync

public CompletionAwaitable<Void> thenRunAsync(Runnable action,
                                              Executor executor)

Specified by:

thenRunAsync in interface CompletionStage<T>

thenCombine

public <U,V> CompletionAwaitable<V> thenCombine(CompletionStage<? extends U> other,
                                                      BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombine in interface CompletionStage<T>

thenCombineAsync

public <U,V> CompletionAwaitable<V> thenCombineAsync(CompletionStage<? extends U> other,
                                                           BiFunction<? super T,? super U,? extends V> fn)

Specified by:

thenCombineAsync in interface CompletionStage<T>

thenCombineAsync

public <U,V> CompletionAwaitable<V> thenCombineAsync(CompletionStage<? extends U> other,
                                                           BiFunction<? super T,? super U,? extends V> fn,
                                                           Executor executor)

Specified by:

thenCombineAsync in interface CompletionStage<T>

thenAcceptBoth

public <U> CompletionAwaitable<Void> thenAcceptBoth(CompletionStage<? extends U> other,
                                                    BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBoth in interface CompletionStage<T>

thenAcceptBothAsync

public <U> CompletionAwaitable<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
                                                         BiConsumer<? super T,? super U> action)

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

thenAcceptBothAsync

public <U> CompletionAwaitable<Void> thenAcceptBothAsync(CompletionStage<? extends U> other,
                                                         BiConsumer<? super T,? super U> action,
                                                         Executor executor)

Specified by:

thenAcceptBothAsync in interface CompletionStage<T>

runAfterBoth

public CompletionAwaitable<Void> runAfterBoth(CompletionStage<?> other,
                                              Runnable action)

Specified by:

runAfterBoth in interface CompletionStage<T>

runAfterBothAsync

public CompletionAwaitable<Void> runAfterBothAsync(CompletionStage<?> other,
                                                   Runnable action)

Specified by:

runAfterBothAsync in interface CompletionStage<T>

runAfterBothAsync

public CompletionAwaitable<Void> runAfterBothAsync(CompletionStage<?> other,
                                                   Runnable action,
                                                   Executor executor)

Specified by:

runAfterBothAsync in interface CompletionStage<T>

applyToEither

public <U> CompletionAwaitable<U> applyToEither(CompletionStage<? extends T> other,
                                                Function<? super T,U> fn)

Specified by:

applyToEither in interface CompletionStage<T>

applyToEitherAsync

public <U> CompletionAwaitable<U> applyToEitherAsync(CompletionStage<? extends T> other,
                                                     Function<? super T,U> fn)

Specified by:

applyToEitherAsync in interface CompletionStage<T>

applyToEitherAsync

public <U> CompletionAwaitable<U> applyToEitherAsync(CompletionStage<? extends T> other,
                                                     Function<? super T,U> fn,
                                                     Executor executor)

Specified by:

applyToEitherAsync in interface CompletionStage<T>

acceptEither

public CompletionAwaitable<Void> acceptEither(CompletionStage<? extends T> other,
                                              Consumer<? super T> action)

Specified by:

acceptEither in interface CompletionStage<T>

acceptEitherAsync

public CompletionAwaitable<Void> acceptEitherAsync(CompletionStage<? extends T> other,
                                                   Consumer<? super T> action)

Specified by:

acceptEitherAsync in interface CompletionStage<T>

acceptEitherAsync

public CompletionAwaitable<Void> acceptEitherAsync(CompletionStage<? extends T> other,
                                                   Consumer<? super T> action,
                                                   Executor executor)

Specified by:

acceptEitherAsync in interface CompletionStage<T>

runAfterEither

public CompletionAwaitable<Void> runAfterEither(CompletionStage<?> other,
                                                Runnable action)

Specified by:

runAfterEither in interface CompletionStage<T>

runAfterEitherAsync

public CompletionAwaitable<Void> runAfterEitherAsync(CompletionStage<?> other,
                                                     Runnable action)

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

runAfterEitherAsync

public CompletionAwaitable<Void> runAfterEitherAsync(CompletionStage<?> other,
                                                     Runnable action,
                                                     Executor executor)

Specified by:

runAfterEitherAsync in interface CompletionStage<T>

thenCompose

public <U> CompletionAwaitable<U> thenCompose(Function<? super T,? extends CompletionStage<U>> fn)

Specified by:

thenCompose in interface CompletionStage<T>

thenComposeAsync

public <U> CompletionAwaitable<U> thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface CompletionStage<T>

thenComposeAsync

public <U> CompletionAwaitable<U> thenComposeAsync(Function<? super T,? extends CompletionStage<U>> fn,
                                                   Executor executor)

Specified by:

thenComposeAsync in interface CompletionStage<T>

handle

public <U> CompletionAwaitable<U> handle(BiFunction<? super T,Throwable,? extends U> fn)

Specified by:

handle in interface CompletionStage<T>

handleAsync

public <U> CompletionAwaitable<U> handleAsync(BiFunction<? super T,Throwable,? extends U> fn)

Specified by:

handleAsync in interface CompletionStage<T>

handleAsync

public <U> CompletionAwaitable<U> handleAsync(BiFunction<? super T,Throwable,? extends U> fn,
                                              Executor executor)

Specified by:

handleAsync in interface CompletionStage<T>

whenComplete

public CompletionAwaitable<T> whenComplete(BiConsumer<? super T,? super Throwable> action)

Specified by:

whenComplete in interface CompletionStage<T>

whenCompleteAsync

public CompletionAwaitable<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action)

Specified by:

whenCompleteAsync in interface CompletionStage<T>

whenCompleteAsync

public CompletionAwaitable<T> whenCompleteAsync(BiConsumer<? super T,? super Throwable> action,
                                                Executor executor)

Specified by:

whenCompleteAsync in interface CompletionStage<T>

exceptionally

public CompletionAwaitable<T> exceptionally(Function<Throwable,? extends T> fn)

Specified by:

exceptionally in interface CompletionStage<T>

exceptionallyAccept

public CompletionAwaitable<T> exceptionallyAccept(Consumer<Throwable> consumer)

Returns a new CompletionAwaitable that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied consumer. Otherwise, if this stage completes normally, then the returned stage also completes normally with the same value.

Parameters:

consumer - the consumer to invoke if this CompletionAwaitable completed exceptionally

Returns:

the new CompletionAwaitable

toCompletableFuture

public CompletableFuture<T> toCompletableFuture()

Description copied from interface: Awaitable

Returns a CompletableFuture maintaining the same completion properties as this stage. If this stage is already a CompletableFuture, this method may return this stage itself. Otherwise, invocation of this method may be equivalent in effect to thenApply(x -> x), but returning an instance of type CompletableFuture.

Specified by:

toCompletableFuture in interface Awaitable<T>

Specified by:

toCompletableFuture in interface CompletionStage<T>

Returns:

the CompletableFuture