Uses of Class
io.helidon.common.reactive.CompletionAwaitable
-
Uses of CompletionAwaitable in io.helidon.common.reactive
Modifier and TypeMethodDescriptionCompletionAwaitable.acceptEither
(CompletionStage<? extends T> other, Consumer<? super T> action) Single.acceptEither
(CompletionStage<? extends T> other, Consumer<? super T> action) CompletionAwaitable.acceptEitherAsync
(CompletionStage<? extends T> other, Consumer<? super T> action) CompletionAwaitable.acceptEitherAsync
(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) Single.acceptEitherAsync
(CompletionStage<? extends T> other, Consumer<? super T> action) Single.acceptEitherAsync
(CompletionStage<? extends T> other, Consumer<? super T> action, Executor executor) <U> CompletionAwaitable
<U> CompletionAwaitable.applyToEither
(CompletionStage<? extends T> other, Function<? super T, U> fn) <U> CompletionAwaitable
<U> Single.applyToEither
(CompletionStage<? extends T> other, Function<? super T, U> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.applyToEitherAsync
(CompletionStage<? extends T> other, Function<? super T, U> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.applyToEitherAsync
(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) <U> CompletionAwaitable
<U> Single.applyToEitherAsync
(CompletionStage<? extends T> other, Function<? super T, U> fn) <U> CompletionAwaitable
<U> Single.applyToEitherAsync
(CompletionStage<? extends T> other, Function<? super T, U> fn, Executor executor) CompletionAwaitable.exceptionally
(Function<Throwable, ? extends T> fn) Single.exceptionally
(Function<Throwable, ? extends T> fn) CompletionAwaitable.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.Single.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.default CompletionAwaitable
<Void> Terminal stage, invokes provided consumer when Single is completed.<U> CompletionAwaitable
<U> CompletionAwaitable.handle
(BiFunction<? super T, Throwable, ? extends U> fn) <U> CompletionAwaitable
<U> Single.handle
(BiFunction<? super T, Throwable, ? extends U> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.handleAsync
(BiFunction<? super T, Throwable, ? extends U> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.handleAsync
(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) <U> CompletionAwaitable
<U> Single.handleAsync
(BiFunction<? super T, Throwable, ? extends U> fn) <U> CompletionAwaitable
<U> Single.handleAsync
(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) default CompletionAwaitable
<Void> Single.ignoreElement()
Terminal stage, ignore onNext signals, only onComplete and onError signals are propagated.CompletionAwaitable.runAfterBoth
(CompletionStage<?> other, Runnable action) Single.runAfterBoth
(CompletionStage<?> other, Runnable action) CompletionAwaitable.runAfterBothAsync
(CompletionStage<?> other, Runnable action) CompletionAwaitable.runAfterBothAsync
(CompletionStage<?> other, Runnable action, Executor executor) Single.runAfterBothAsync
(CompletionStage<?> other, Runnable action) Single.runAfterBothAsync
(CompletionStage<?> other, Runnable action, Executor executor) CompletionAwaitable.runAfterEither
(CompletionStage<?> other, Runnable action) Single.runAfterEither
(CompletionStage<?> other, Runnable action) CompletionAwaitable.runAfterEitherAsync
(CompletionStage<?> other, Runnable action) CompletionAwaitable.runAfterEitherAsync
(CompletionStage<?> other, Runnable action, Executor executor) Single.runAfterEitherAsync
(CompletionStage<?> other, Runnable action) Single.runAfterEitherAsync
(CompletionStage<?> other, Runnable action, Executor executor) CompletionAwaitable.thenAccept
(Consumer<? super T> action) Single.thenAccept
(Consumer<? super T> action) CompletionAwaitable.thenAcceptAsync
(Consumer<? super T> action) CompletionAwaitable.thenAcceptAsync
(Consumer<? super T> action, Executor executor) Single.thenAcceptAsync
(Consumer<? super T> action) Single.thenAcceptAsync
(Consumer<? super T> action, Executor executor) <U> CompletionAwaitable
<Void> CompletionAwaitable.thenAcceptBoth
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action) <U> CompletionAwaitable
<Void> Single.thenAcceptBoth
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action) <U> CompletionAwaitable
<Void> CompletionAwaitable.thenAcceptBothAsync
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action) <U> CompletionAwaitable
<Void> CompletionAwaitable.thenAcceptBothAsync
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) <U> CompletionAwaitable
<Void> Single.thenAcceptBothAsync
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action) <U> CompletionAwaitable
<Void> Single.thenAcceptBothAsync
(CompletionStage<? extends U> other, BiConsumer<? super T, ? super U> action, Executor executor) <U> CompletionAwaitable
<U> <U> CompletionAwaitable
<U> <U> CompletionAwaitable
<U> CompletionAwaitable.thenApplyAsync
(Function<? super T, ? extends U> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.thenApplyAsync
(Function<? super T, ? extends U> fn, Executor executor) <U> CompletionAwaitable
<U> Single.thenApplyAsync
(Function<? super T, ? extends U> fn) <U> CompletionAwaitable
<U> Single.thenApplyAsync
(Function<? super T, ? extends U> fn, Executor executor) <U,
V> CompletionAwaitable <V> CompletionAwaitable.thenCombine
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn) <U,
V> CompletionAwaitable <V> Single.thenCombine
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn) <U,
V> CompletionAwaitable <V> CompletionAwaitable.thenCombineAsync
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn) <U,
V> CompletionAwaitable <V> CompletionAwaitable.thenCombineAsync
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor) <U,
V> CompletionAwaitable <V> Single.thenCombineAsync
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn) <U,
V> CompletionAwaitable <V> Single.thenCombineAsync
(CompletionStage<? extends U> other, BiFunction<? super T, ? super U, ? extends V> fn, Executor executor) <U> CompletionAwaitable
<U> CompletionAwaitable.thenCompose
(Function<? super T, ? extends CompletionStage<U>> fn) <U> CompletionAwaitable
<U> Single.thenCompose
(Function<? super T, ? extends CompletionStage<U>> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.thenComposeAsync
(Function<? super T, ? extends CompletionStage<U>> fn) <U> CompletionAwaitable
<U> CompletionAwaitable.thenComposeAsync
(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) <U> CompletionAwaitable
<U> Single.thenComposeAsync
(Function<? super T, ? extends CompletionStage<U>> fn) <U> CompletionAwaitable
<U> Single.thenComposeAsync
(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor) CompletionAwaitable.thenRunAsync
(Runnable action) CompletionAwaitable.thenRunAsync
(Runnable action, Executor executor) Single.thenRunAsync
(Runnable action) Single.thenRunAsync
(Runnable action, Executor executor) CompletionAwaitable.whenComplete
(BiConsumer<? super T, ? super Throwable> action) Single.whenComplete
(BiConsumer<? super T, ? super Throwable> action) CompletionAwaitable.whenCompleteAsync
(BiConsumer<? super T, ? super Throwable> action) CompletionAwaitable.whenCompleteAsync
(BiConsumer<? super T, ? super Throwable> action, Executor executor) Single.whenCompleteAsync
(BiConsumer<? super T, ? super Throwable> action) Single.whenCompleteAsync
(BiConsumer<? super T, ? super Throwable> action, Executor executor)