Class SubscribableCompletable
- java.lang.Object
-
- io.servicetalk.concurrent.api.Completable
-
- io.servicetalk.concurrent.api.internal.SubscribableCompletable
-
- All Implemented Interfaces:
CompletableSource
- Direct Known Subclasses:
NettyFutureCompletable
public abstract class SubscribableCompletable extends Completable implements CompletableSource
ACompletablethat is also aCompletableSourceand hence can be subscribed.Typically, this will be used to implement a
Completablethat does not require an additional allocation when converting to aCompletableSourceviaSourceAdapters.toSource(Completable).
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource
CompletableSource.Processor, CompletableSource.Subscriber
-
-
Constructor Summary
Constructors Constructor Description SubscribableCompletable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidsubscribe(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, completed, concat, concat, concat, defer, failed, fromFuture, fromRunnable, fromStage, handleSubscribe, idleTimeout, idleTimeout, idleTimeout, idleTimeout, 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, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, repeat, repeatWhen, retry, retryWhen, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, timeout, timeout, timeout, timeout, toCompletionStage, toFuture, toPublisher, toSingle, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnSubscribe, whenSubscriber
-
-
-
-
Method Detail
-
subscribe
public final void subscribe(CompletableSource.Subscriber subscriber)
Description copied from interface:CompletableSourceSubscribes to the outcome of thisCompletableSource.- Specified by:
subscribein interfaceCompletableSource- Parameters:
subscriber- of the outcome.- See Also:
PublisherSource.subscribe(PublisherSource.Subscriber)
-
-