Class CancelledSubscriber<T>

java.lang.Object
software.amazon.awssdk.http.nio.netty.internal.nrs.CancelledSubscriber<T>
All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
@SdkInternalApi public final class CancelledSubscriber<T> extends Object implements org.reactivestreams.Subscriber<T>
A cancelled subscriber. This class contains source imported from https://github.com/playframework/netty-reactive-streams, licensed under the Apache License 2.0, available at the time of the fork (1/31/2020) here: https://github.com/playframework/netty-reactive-streams/blob/master/LICENSE.txt All original source licensed under the Apache License 2.0 by playframework. All modifications are licensed under the Apache License 2.0 by Amazon Web Services.

  • Constructor Details

    • CancelledSubscriber

      public CancelledSubscriber()

  • Method Details

    • onSubscribe

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

    • onNext

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

    • onError

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

    • onComplete

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