Uses of Class
io.helidon.common.reactive.CompletionAwaitable
Packages that use CompletionAwaitable
-
Uses of CompletionAwaitable in io.helidon.common.reactive
Subclasses of CompletionAwaitable in io.helidon.common.reactiveMethods in io.helidon.common.reactive that return CompletionAwaitableModifier 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)