Package software.amazon.awssdk.utils.async

Class BaseSubscriberAdapter<T,U>

java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<T,U>
software.amazon.awssdk.utils.async.BaseSubscriberAdapter<T,U>
Type Parameters:
T - the type that the delegate subscriber demands.
U - the type sent by the publisher this subscriber is subscribed to.
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
Direct Known Subclasses:
DelegatingBufferingSubscriber, FlatteningSubscriber
public abstract class BaseSubscriberAdapter<T,U> extends DelegatingSubscriber<T,U>
Base of subscribers that can adapt one type to another. This subscriber will receive onNext signal with the U type, but will need to fulfill the downstream demand of the delegate subscriber with instance of the T type.

  • Method Details

    • onSubscribe

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

    • onNext

      public void onNext(T item)

    • onError

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

    • onComplete

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