Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class CompletionSingle<T>

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()	Create a new completion single using toNullableStage() as a supplier for CompletionAwaitable.setOriginalStage(java.util.function.Supplier).

Method Summary

Modifier and Type	Method	Description
Single<T>	cancel()	Cancel upstream.
Single<T>	onCancel(Runnable onCancel)	Executes given Runnable when a cancel signal is received.
protected CompletableFuture<T>	toNullableStage()	Create a new nullable completable future from this single.

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

exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, 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

Constructor Details

CompletionSingle

protected CompletionSingle()

Create a new completion single using toNullableStage() as a supplier for CompletionAwaitable.setOriginalStage(java.util.function.Supplier).

Method Details

toNullableStage

protected CompletableFuture<T> toNullableStage()

Create a new nullable completable future from this single.

Returns:

a new nullable completable future

onCancel

public Single<T> onCancel(Runnable onCancel)

Description copied from interface: Single

Executes given Runnable when a cancel signal is received.

Specified by:

onCancel in interface Single<T>

Specified by:

onCancel in interface Subscribable<T>

Parameters:

onCancel - Runnable to be executed.

Returns:

Single

cancel

public Single<T> cancel()

Description copied from interface: Single

Cancel upstream.

Specified by:

cancel in interface Single<T>

Returns:

new Single for eventually received single value.