Package io.servicetalk.concurrent.api
Class RunnableCompletable
- java.lang.Object
-
- io.servicetalk.concurrent.api.Completable
-
- io.servicetalk.concurrent.api.RunnableCompletable
-
- All Implemented Interfaces:
CompletableSource
public class RunnableCompletable extends Completable
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.CompletableSource
CompletableSource.Processor, CompletableSource.Subscriber
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidhandleSubscribe(CompletableSource.Subscriber subscriber)Handles a subscriber to thisCompletable.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, 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
-
handleSubscribe
protected final void handleSubscribe(CompletableSource.Subscriber subscriber)
Description copied from class:CompletableHandles a subscriber to thisCompletable.This method is invoked internally by
Completablefor every call to theCompletable.subscribeInternal(CompletableSource.Subscriber)method.- Specified by:
handleSubscribein classCompletable- Parameters:
subscriber- the subscriber.
-
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)
-
-