Package io.servicetalk.concurrent

Interface CompletableSource.Subscriber

All Known Subinterfaces:

CompletableSource.Processor

All Known Implementing Classes:

TestCompletableSubscriber

Enclosing interface:

CompletableSource

public static interface CompletableSource.Subscriber

Subscriber of the outcome of a Cancellable.

The semantics and threading model of this interface is meant to be the same as PublisherSource.Subscriber, but simplified for the use case where the operations completes or fails with no data.

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Success terminal state.
void	onError(Throwable t)	Failed terminal state.
void	onSubscribe(Cancellable cancellable)	Called when the associated CompletableSource is subscribed via CompletableSource.subscribe(Subscriber).

Method Details

onSubscribe

void onSubscribe(Cancellable cancellable)

Called when the associated CompletableSource is subscribed via CompletableSource.subscribe(Subscriber).

Parameters:

cancellable - A Cancellable that can be used to cancel the asynchronous computation for this subscriber.

onComplete

void onComplete()

Success terminal state.

No further events will be sent.

onError

void onError(Throwable t)

Failed terminal state.

No further events will be sent.

Parameters:

t - the throwable signaled