- java.lang.Object
-
- io.helidon.common.reactive.CompletionAwaitable<T>
-
- io.helidon.common.reactive.CompletionSingle<T>
-
- Type Parameters:
T
- payload type
- All Implemented Interfaces:
Awaitable<T>
,Single<T>
,Subscribable<T>
,CompletionStage<T>
,Flow.Publisher<T>
public abstract class CompletionSingle<T> extends CompletionAwaitable<T> implements Single<T>
Single as CompletionStage.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
CompletionSingle()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Single<T>
cancel()
Cancel upstream.Single<T>
onCancel(Runnable onCancel)
Executes givenRunnable
when a cancel signal is received.protected CompletableFuture<T>
toNullableStage()
-
Methods inherited from class io.helidon.common.reactive.CompletionAwaitable
acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, exceptionallyAccept, handle, handleAsync, handleAsync, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync
-
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, toCompletableFuture
-
Methods inherited from interface java.util.concurrent.CompletionStage
toCompletableFuture
-
Methods inherited from interface java.util.concurrent.Flow.Publisher
subscribe
-
Methods inherited from interface io.helidon.common.reactive.Single
acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, compose, defaultIfEmpty, defaultIfEmpty, exceptionally, exceptionallyAccept, flatMap, flatMapCompletionStage, flatMapIterable, flatMapOptional, flatMapSingle, forSingle, get, get, handle, handleAsync, handleAsync, ifEmpty, ignoreElement, log, log, log, log, map, observeOn, onComplete, onCompleteResume, onCompleteResumeWith, onCompleteResumeWithSingle, onError, onErrorResume, onErrorResumeWith, onErrorResumeWithSingle, onTerminate, peek, retry, retry, retryWhen, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, switchIfEmpty, takeUntil, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, timeout, timeout, to, toOptionalSingle, toStage, toStage, whenComplete, whenCompleteAsync, whenCompleteAsync
-
Methods inherited from interface io.helidon.common.reactive.Subscribable
subscribe, subscribe, subscribe, subscribe
-
-