Class SimpleSubscriber

java.lang.Object
software.amazon.awssdk.http.async.SimpleSubscriber
All Implemented Interfaces:
org.reactivestreams.Subscriber<ByteBuffer>
public class SimpleSubscriber extends Object implements org.reactivestreams.Subscriber<ByteBuffer>
Simple subscriber that does no backpressure and doesn't care about errors or completion.

  • Constructor Details

  • Method Details

    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription s)
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onNext

      public void onNext(ByteBuffer byteBuffer)
      Specified by:
      onNext in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onError

      public void onError(Throwable t)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>