Package io.servicetalk.concurrent.api.internal

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

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

Constructors

Constructor	Description
SubscribableCompletable()

Method Summary

Modifier and Type	Method	Description
final void	subscribe(CompletableSource.Subscriber subscriber)	Subscribes to the outcome of this CompletableSource.

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, subscribe, subscribeInternal, subscribeOn, subscribeOn, timeout, timeout, timeout, timeout, toCompletionStage, toFuture, toPublisher, toSingle, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnSubscribe, whenSubscriber

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SubscribableCompletable

public SubscribableCompletable()

Method Details

subscribe

public final void subscribe(CompletableSource.Subscriber subscriber)

Description copied from interface: CompletableSource

Subscribes to the outcome of this CompletableSource.

Specified by:

subscribe in interface CompletableSource

Parameters:

subscriber - of the outcome.

See Also:

• PublisherSource.subscribe(PublisherSource.Subscriber)