com.ibm.cos.v2.core.async.listener

Interface AsyncResponseTransformerListener<ResponseT>

All Superinterfaces:

PublisherListener<ByteBuffer>, SubscriberListener<ByteBuffer>

public interface AsyncResponseTransformerListener<ResponseT>
extends PublisherListener<ByteBuffer>

Listener interface that invokes callbacks associated with a AsyncResponseTransformer and any resulting SdkPublisher and Subscriber.

See Also:

PublisherListener, SubscriberListener

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	AsyncResponseTransformerListener.NotifyingAsyncResponseTransformer<ResponseT,ResultT>

Nested classes/interfaces inherited from interface com.ibm.cos.v2.core.async.listener.PublisherListener

PublisherListener.NoOpPublisherListener, PublisherListener.NotifyingPublisher<T>

Nested classes/interfaces inherited from interface com.ibm.cos.v2.core.async.listener.SubscriberListener

SubscriberListener.NotifyingSubscriber<T>

Method Summary

Modifier and Type	Method and Description
default void	transformerExceptionOccurred(Throwable t) Invoked before AsyncResponseTransformer.exceptionOccurred(Throwable)
default void	transformerOnResponse(ResponseT response) Invoked before AsyncResponseTransformer.onResponse(Object)
default void	transformerOnStream(SdkPublisher<ByteBuffer> publisher) Invoked before AsyncResponseTransformer.onStream(SdkPublisher)
static <ResponseT,ResultT> AsyncResponseTransformer<ResponseT,ResultT>	wrap(AsyncResponseTransformer<ResponseT,ResultT> delegate, AsyncResponseTransformerListener<ResponseT> listener) Wrap a AsyncResponseTransformer with a new one that will notify a AsyncResponseTransformerListener of important events occurring.

Methods inherited from interface com.ibm.cos.v2.core.async.listener.PublisherListener

noOp, publisherSubscribe, wrap

Methods inherited from interface com.ibm.cos.v2.core.async.listener.SubscriberListener

subscriberOnComplete, subscriberOnError, subscriberOnNext, subscriptionCancel, wrap

Method Detail

transformerOnResponse

default void transformerOnResponse(ResponseT response)

Invoked before AsyncResponseTransformer.onResponse(Object)

transformerOnStream

default void transformerOnStream(SdkPublisher<ByteBuffer> publisher)

Invoked before AsyncResponseTransformer.onStream(SdkPublisher)

transformerExceptionOccurred

default void transformerExceptionOccurred(Throwable t)

Invoked before AsyncResponseTransformer.exceptionOccurred(Throwable)

wrap

static <ResponseT,ResultT> AsyncResponseTransformer<ResponseT,ResultT> wrap(AsyncResponseTransformer<ResponseT,ResultT> delegate,
                                                                            AsyncResponseTransformerListener<ResponseT> listener)

Wrap a AsyncResponseTransformer with a new one that will notify a AsyncResponseTransformerListener of important events occurring.