Package software.amazon.awssdk.utils.async

Class BufferingSubscriber<T>

java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<T,List<T>>
software.amazon.awssdk.utils.async.BufferingSubscriber<T>
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
public class BufferingSubscriber<T> extends DelegatingSubscriber<T,List<T>>

  • Constructor Details

    • BufferingSubscriber

      public BufferingSubscriber(org.reactivestreams.Subscriber<? super List<T>> subscriber, int bufferSize)

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