Package io.servicetalk.concurrent.api

Interface SingleTerminalSignalConsumer<T>

Type Parameters:

T - Type of the result of the Single.

public interface SingleTerminalSignalConsumer<T>

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

Method Summary

Modifier and Type	Method	Description
void	cancel()	Callback to indicate termination via Cancellable.cancel().
static <X> SingleTerminalSignalConsumer<X>	from(Runnable runnable)	Create a SingleTerminalSignalConsumer where each method executes a Runnable.run().
void	onError(Throwable throwable)	Callback to indicate termination via SingleSource.Subscriber.onError(Throwable).
void	onSuccess(T result)	Callback to indicate termination via SingleSource.Subscriber.onSuccess(Object).

Method Details

onSuccess

void onSuccess(@Nullable
 T result)

Callback to indicate termination via SingleSource.Subscriber.onSuccess(Object).

Parameters:

result - the observed result of type SingleTerminalSignalConsumer.

onError

void onError(Throwable throwable)

Callback to indicate termination via SingleSource.Subscriber.onError(Throwable).

Parameters:

throwable - the observed Throwable.

cancel

void cancel()

Callback to indicate termination via Cancellable.cancel().

from

static <X> SingleTerminalSignalConsumer<X> from(Runnable runnable)

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

Type Parameters:

X - The type of SingleTerminalSignalConsumer.

Parameters:

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

Returns:

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