Class SubscribableCompletable
java.lang.Object
io.servicetalk.concurrent.api.Completable
io.servicetalk.concurrent.api.internal.SubscribableCompletable
- All Implemented Interfaces:
CompletableSource
- Direct Known Subclasses:
NettyFutureCompletable
A
Completable
that is also a CompletableSource
and hence can be subscribed.
Typically, this will be used to implement a Completable
that does not require an additional allocation when
converting to a CompletableSource
via SourceAdapters.toSource(Completable)
.
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource
CompletableSource.Processor, CompletableSource.Subscriber
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionfinal void
subscribe
(CompletableSource.Subscriber subscriber) Subscribes to the outcome of thisCompletableSource
.Methods inherited from class io.servicetalk.concurrent.api.Completable
afterCancel, afterFinally, afterFinally, afterOnComplete, afterOnError, afterOnSubscribe, afterSubscriber, amb, amb, ambWith, anyOf, anyOf, beforeCancel, beforeFinally, beforeFinally, beforeOnComplete, beforeOnError, beforeOnSubscribe, beforeSubscriber, cache, cache, cache, cache, completed, concat, concat, concat, concat, defer, failed, fromCallable, fromFuture, fromRunnable, fromStage, handleSubscribe, liftAsync, liftSync, merge, merge, merge, merge, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, never, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, publishOn, publishOn, repeat, repeatWhen, retry, retryWhen, setContextOnSubscribe, shareContextOnSubscribe, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOn, timeout, timeout, timeout, timeout, toCompletionStage, toFuture, toPublisher, toSingle, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnSubscribe, whenSubscriber
-
Constructor Details
-
SubscribableCompletable
public SubscribableCompletable()
-
-
Method Details
-
subscribe
Description copied from interface:CompletableSource
Subscribes to the outcome of thisCompletableSource
.- Specified by:
subscribe
in interfaceCompletableSource
- Parameters:
subscriber
- of the outcome.- See Also:
-