Package software.amazon.awssdk.core.async.listener

Interface AsyncResponseTransformerListener<ResponseT>

All Superinterfaces:

PublisherListener<ByteBuffer>, SubscriberListener<ByteBuffer>

@SdkProtectedApi
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	Description
static final class	AsyncResponseTransformerListener.NotifyingAsyncResponseTransformer<ResponseT,ResultT>

Nested classes/interfaces inherited from interface software.amazon.awssdk.core.async.listener.PublisherListener

PublisherListener.NoOpPublisherListener, PublisherListener.NotifyingPublisher<T>

Nested classes/interfaces inherited from interface software.amazon.awssdk.core.async.listener.SubscriberListener

SubscriberListener.NotifyingSubscriber<T>

Method Summary

Modifier and Type	Method	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 software.amazon.awssdk.core.async.listener.PublisherListener

publisherSubscribe

Methods inherited from interface software.amazon.awssdk.core.async.listener.SubscriberListener

subscriberOnComplete, subscriberOnError, subscriberOnNext, subscriptionCancel

Method Details

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.