io.servicetalk.concurrent.internal

Class EmptySubscription

java.lang.Object

io.servicetalk.concurrent.internal.EmptySubscription

All Implemented Interfaces:

Cancellable, PublisherSource.Subscription

public final class EmptySubscription
extends java.lang.Object
implements PublisherSource.Subscription

A PublisherSource.Subscription implementation, which does not do anything.

Field Summary

Fields

Modifier and Type	Field and Description
static EmptySubscription	EMPTY_SUBSCRIPTION

Fields inherited from interface io.servicetalk.concurrent.Cancellable

IGNORE_CANCEL

Constructor Summary

Constructors

Constructor and Description
EmptySubscription()

Method Summary

Modifier and Type	Method and Description
void	cancel() Sends a hint to the producer of the associated asynchronous execution that the consumer related to this Cancellable is not interested in the outcome of the execution.
void	request(long n) Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_SUBSCRIPTION

public static final EmptySubscription EMPTY_SUBSCRIPTION

Constructor Detail

EmptySubscription

public EmptySubscription()

Method Detail

request

public void request(long n)

Description copied from interface: PublisherSource.Subscription

Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

request in interface PublisherSource.Subscription

Parameters:

n - Number of items to request.

cancel

public void cancel()

Description copied from interface: Cancellable

Sends a hint to the producer of the associated asynchronous execution that the consumer related to this Cancellable is not interested in the outcome of the execution.

Specified by:

cancel in interface Cancellable