Class EventListeningSubscriber<T>

java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<T,T>
software.amazon.awssdk.utils.async.EventListeningSubscriber<T>
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>

public final class EventListeningSubscriber<T> extends DelegatingSubscriber<T,T>
A Subscriber that can invoke callbacks during various parts of the subscriber and subscription lifecycle.
  • Constructor Details

    • EventListeningSubscriber

      public EventListeningSubscriber(org.reactivestreams.Subscriber<T> subscriber, Runnable afterCompleteListener, Consumer<Throwable> afterErrorListener, Runnable afterCancelListener)
  • Method Details

    • onNext

      public void onNext(T t)
    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription subscription)
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<T>
      Overrides:
      onSubscribe in class DelegatingSubscriber<T,T>
    • onError

      public void onError(Throwable throwable)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<T>
      Overrides:
      onError in class DelegatingSubscriber<T,T>
    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<T>
      Overrides:
      onComplete in class DelegatingSubscriber<T,T>