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

Interface SubscriberListener<T>

All Known Subinterfaces:
AsyncRequestBodyListener, AsyncResponseTransformerListener<ResponseT>, PublisherListener<T>
All Known Implementing Classes:
PublisherListener.NoOpPublisherListener
@SdkProtectedApi public interface SubscriberListener<T>
Listener interface that invokes callbacks associated with a Subscriber.
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static final class 
    SubscriberListener.NotifyingSubscriber<T>
     

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    subscriberOnComplete()
    Invoked before Subscriber.onComplete()
    default void
    subscriberOnError(Throwable t)
    Invoked before Subscriber.onError(Throwable)
    default void
    subscriberOnNext(T t)
    Invoked before Subscriber.onNext(Object)
    default void
    subscriptionCancel()
    Invoked before Subscription.cancel()
    static <T> org.reactivestreams.Subscriber<T>
    wrap(org.reactivestreams.Subscriber<? super T> delegate, SubscriberListener<? super T> listener)
    Wrap a Subscriber with a new one that will notify a SubscriberListener of important events occurring.

  • Method Details

    • subscriberOnNext

      default void subscriberOnNext(T t)
      Invoked before Subscriber.onNext(Object)

    • subscriberOnComplete

      default void subscriberOnComplete()
      Invoked before Subscriber.onComplete()

    • subscriberOnError

      default void subscriberOnError(Throwable t)
      Invoked before Subscriber.onError(Throwable)

    • subscriptionCancel

      default void subscriptionCancel()
      Invoked before Subscription.cancel()

    • wrap

      static <T> org.reactivestreams.Subscriber<T> wrap(org.reactivestreams.Subscriber<? super T> delegate, SubscriberListener<? super T> listener)
      Wrap a Subscriber with a new one that will notify a SubscriberListener of important events occurring.