software.amazon.awssdk.core.internal.util

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 onError or onComplete immediately after subscribe() but but it needs to signalonSubscription first.

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopSubscription

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

Method Detail

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