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
ACompletable
that is also aCompletableSource
and hence can be subscribed.Typically, this will be used to implement a
Completable
that does not require an additional allocation when converting to aCompletableSource
viaSourceAdapters.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 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, 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, onErrorResume, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, repeat, repeatWhen, retry, retryWhen, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, 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:CompletableSource
Subscribes to the outcome of thisCompletableSource
.- Specified by:
subscribe
in interfaceCompletableSource
- Parameters:
subscriber
- of the outcome.- See Also:
PublisherSource.subscribe(PublisherSource.Subscriber)
-
-