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

Modifier and Type	Method and Description
protected void	handleSubscribe(CompletableSource.Subscriber subscriber) Handles a subscriber to this Completable.
void	subscribe(CompletableSource.Subscriber subscriber) Subscribes to the outcome of this CompletableSource.

Methods inherited from class io.servicetalk.concurrent.api.Completable

afterCancel, afterFinally, afterOnComplete, afterOnError, afterOnSubscribe, afterSubscriber, beforeCancel, beforeFinally, beforeOnComplete, beforeOnError, beforeOnSubscribe, beforeSubscriber, completed, concat, concat, concat, defer, failed, fromFuture, fromRunnable, fromStage, idleTimeout, idleTimeout, idleTimeout, idleTimeout, liftAsync, liftSync, merge, merge, merge, mergeAll, mergeAll, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeAllDelayError, mergeDelayError, mergeDelayError, never, onErrorResume, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, repeat, repeatWhen, retry, retryWhen, subscribe, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, toCompletionStage, toFuture, toPublisher, toSingle, whenCancel, whenFinally, whenOnComplete, whenOnError, whenOnSubscribe, whenSubscriber

Methods inherited from class java.lang.Object

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

Method Detail

handleSubscribe

protected final void handleSubscribe(CompletableSource.Subscriber subscriber)

Description copied from class: Completable

Handles a subscriber to this Completable.

This method is invoked internally by Completable for every call to the Completable.subscribeInternal(CompletableSource.Subscriber) method.

Specified by:

handleSubscribe in class Completable

Parameters:

subscriber - the subscriber.

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)