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

Interface PublisherListener<T>

All Superinterfaces:

SubscriberListener<T>

All Known Subinterfaces:

AsyncRequestBodyListener, AsyncResponseTransformerListener<ResponseT>

All Known Implementing Classes:

PublisherListener.NoOpPublisherListener

@SdkProtectedApi
public interface PublisherListener<T>
extends SubscriberListener<T>

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

See Also:

• AsyncResponseTransformerListener
• SubscriberListener

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	PublisherListener.NoOpPublisherListener
static final class	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
static PublisherListener.NoOpPublisherListener	noOp()
default void	publisherSubscribe(org.reactivestreams.Subscriber<? super T> subscriber)	Invoked before Publisher.subscribe(Subscriber)
static <T> SdkPublisher<T>	wrap(SdkPublisher<T> delegate, PublisherListener<T> listener)	Wrap a SdkPublisher with a new one that will notify a PublisherListener of important events occurring.

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

subscriberOnComplete, subscriberOnError, subscriberOnNext, subscriptionCancel

Method Details

publisherSubscribe

default void publisherSubscribe(org.reactivestreams.Subscriber<? super T> subscriber)

Invoked before Publisher.subscribe(Subscriber)

wrap

static <T> SdkPublisher<T> wrap(SdkPublisher<T> delegate,
 PublisherListener<T> listener)

Wrap a SdkPublisher with a new one that will notify a PublisherListener of important events occurring.

noOp

static PublisherListener.NoOpPublisherListener noOp()