Class NoopSubscription

java.lang.Object
software.amazon.awssdk.core.internal.util.NoopSubscription
All Implemented Interfaces:
org.reactivestreams.Subscription

public final class NoopSubscription extends Object implements org.reactivestreams.Subscription
An implementation of Subscription that does nothing.

Useful in situations where a Publisher needs to signal exceptionOccurred or onComplete immediately after subscribe() but but it needs to signalonSubscription first.

  • Constructor Details

    • NoopSubscription

      public NoopSubscription(org.reactivestreams.Subscriber<?> subscriber)
  • Method Details

    • request

      public void request(long l)
      Specified by:
      request in interface org.reactivestreams.Subscription
    • cancel

      public void cancel()
      Specified by:
      cancel in interface org.reactivestreams.Subscription