Package software.amazon.awssdk.utils.internal.async

Class EmptySubscription

java.lang.Object

software.amazon.awssdk.utils.internal.async.EmptySubscription

All Implemented Interfaces:

org.reactivestreams.Subscription

public final class EmptySubscription
extends Object
implements org.reactivestreams.Subscription

A NoOp implementation of Subscription interface. This subscription calls Subscriber.onComplete() on first request for data and then terminates the subscription.

Constructor Summary

Constructors

Constructor	Description
EmptySubscription(org.reactivestreams.Subscriber<?> subscriber)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	request(long n)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EmptySubscription

public EmptySubscription(org.reactivestreams.Subscriber<?> subscriber)

Method Details

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription