Package io.servicetalk.concurrent.api

Class LoggingCompletableSubscriber

java.lang.Object

io.servicetalk.concurrent.api.LoggingCompletableSubscriber

All Implemented Interfaces:

CompletableSource.Subscriber

public class LoggingCompletableSubscriber
extends java.lang.Object
implements CompletableSource.Subscriber

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

Constructor Summary

Constructors

Constructor	Description
LoggingCompletableSubscriber(java.lang.String name, CompletableSource.Subscriber delegate)	Create a LoggingCompletableSubscriber that wraps the delegate, and uses the specified name for logging.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LoggingCompletableSubscriber

public LoggingCompletableSubscriber(java.lang.String name,
                                    CompletableSource.Subscriber delegate)

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

Parameters:

name - the logging name.

delegate - the CompletableSource.Subscriber to delegate calls to.

Method Detail

onSubscribe

public void onSubscribe(Cancellable c)

Description copied from interface: CompletableSource.Subscriber

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

Specified by:

onSubscribe in interface CompletableSource.Subscriber

Parameters:

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

onComplete

public void onComplete()

Description copied from interface: CompletableSource.Subscriber

Success terminal state.

No further events will be sent.

Specified by:

onComplete in interface CompletableSource.Subscriber

onError

public void onError(java.lang.Throwable t)

Description copied from interface: CompletableSource.Subscriber

Failed terminal state.

No further events will be sent.

Specified by:

onError in interface CompletableSource.Subscriber

Parameters:

t - the throwable signaled