Class AddingTrailingDataSubscriber<T>

java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<T,T>
software.amazon.awssdk.utils.async.AddingTrailingDataSubscriber<T>
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
@SdkProtectedApi public class AddingTrailingDataSubscriber<T> extends DelegatingSubscriber<T,T>
Allows to send trailing data before invoking onComplete on the downstream subscriber. trailingDataIterable will be created when the upstream subscriber has called onComplete.

  • Constructor Details

    • AddingTrailingDataSubscriber

      public AddingTrailingDataSubscriber(org.reactivestreams.Subscriber<? super T> subscriber, Supplier<Iterable<T>> trailingDataIterableSupplier)

  • 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,T>

    • onError

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

    • onNext

      public void onNext(T t)

    • onComplete

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