Package io.servicetalk.concurrent.api

Interface TerminalSignalConsumer

public interface TerminalSignalConsumer

A contract that provides discrete callbacks for various ways in which a PublisherSource.Subscriber or a CompletableSource.Subscriber can terminate.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Callback to indicate termination via Cancellable.cancel().
static TerminalSignalConsumer	from(Runnable runnable)	Create a TerminalSignalConsumer where each method executes a Runnable.run().
void	onComplete()	Callback to indicate termination via PublisherSource.Subscriber.onComplete() or CompletableSource.Subscriber.onComplete().
void	onError(Throwable throwable)	Callback to indicate termination via PublisherSource.Subscriber.onError(Throwable) or CompletableSource.Subscriber.onError(Throwable).

Method Details

onComplete

void onComplete()

Callback to indicate termination via PublisherSource.Subscriber.onComplete() or CompletableSource.Subscriber.onComplete().

onError

void onError(Throwable throwable)

Callback to indicate termination via PublisherSource.Subscriber.onError(Throwable) or CompletableSource.Subscriber.onError(Throwable).

Parameters:

throwable - the observed Throwable.

cancel

void cancel()

Callback to indicate termination via Cancellable.cancel().

from

static TerminalSignalConsumer from(Runnable runnable)

Create a TerminalSignalConsumer where each method executes a Runnable.run().

Parameters:

runnable - The Runnable which is invoked in each method of the returned TerminalSignalConsumer.

Returns:

a TerminalSignalConsumer where each method executes a Runnable.run().