io.servicetalk.concurrent

Interface SingleSource.Subscriber<T>

Type Parameters:

T - Type of the result of the SingleSource.

All Known Subinterfaces:

SingleSource.Processor<T,R>

Enclosing interface:

SingleSource<T>

public static interface SingleSource.Subscriber<T>

Subscriber of the outcome of a SingleSource.

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 with a single data element or fails.

Method Summary

Modifier and Type	Method and Description
void	onError(java.lang.Throwable t) Failed terminal state.
void	onSubscribe(Cancellable cancellable) Called when the associated SingleSource is subscribed via SingleSource.subscribe(Subscriber).
void	onSuccess(T result) Success terminal state.

Method Detail

onSubscribe

void onSubscribe(Cancellable cancellable)

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

Parameters:

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

onSuccess

void onSuccess(@Nullable
               T result)

Success terminal state.

No further events will be sent.

Parameters:

result - of the SingleSource.

onError

void onError(java.lang.Throwable t)

Failed terminal state.

No further events will be sent.

Parameters:

t - the throwable signaled.