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 void
handleSubscribe(CompletableSource.Subscriber subscriber)
Handles a subscriber to thisCompletable
.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, 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:Completable
Handles a subscriber to thisCompletable
.This method is invoked internally by
Completable
for every call to theCompletable.subscribeInternal(CompletableSource.Subscriber)
method.- Specified by:
handleSubscribe
in classCompletable
- Parameters:
subscriber
- the subscriber.
-
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)
-
-