Package io.servicetalk.concurrent.api

Class LoggingSingleSubscriber<T>

java.lang.Object

io.servicetalk.concurrent.api.LoggingSingleSubscriber<T>

Type Parameters:

T - Type of items received by the Subscriber.

All Implemented Interfaces:

SingleSource.Subscriber<T>

public class LoggingSingleSubscriber<T>
extends java.lang.Object
implements SingleSource.Subscriber<T>

A SingleSource.Subscriber that wraps another SingleSource.Subscriber, logging all signals received by the SingleSource.Subscriber, or sent via the Cancellable.

Constructor Summary

Constructors

Constructor	Description
LoggingSingleSubscriber(java.lang.String name, SingleSource.Subscriber<T> delegate)	Create a LoggingSingleSubscriber that wraps the delegate, and uses the specified name for logging.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LoggingSingleSubscriber

public LoggingSingleSubscriber(java.lang.String name,
                               SingleSource.Subscriber<T> delegate)

Create a LoggingSingleSubscriber that wraps the delegate, and uses the specified name for logging.

Parameters:

name - the logging name.

delegate - the SingleSource.Subscriber to delegate calls to.

Method Detail

onSubscribe

public void onSubscribe(Cancellable c)

Description copied from interface: SingleSource.Subscriber

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

Specified by:

onSubscribe in interface SingleSource.Subscriber<T>

Parameters:

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

onSuccess

public void onSuccess(T result)

Description copied from interface: SingleSource.Subscriber

Success terminal state.

No further events will be sent.

Specified by:

onSuccess in interface SingleSource.Subscriber<T>

Parameters:

result - of the SingleSource.

onError

public void onError(java.lang.Throwable t)

Description copied from interface: SingleSource.Subscriber

Failed terminal state.

No further events will be sent.

Specified by:

onError in interface SingleSource.Subscriber<T>

Parameters:

t - the throwable signaled.