Package io.servicetalk.concurrent.internal

Class DelayedSubscription

java.lang.Object

io.servicetalk.concurrent.internal.DelayedSubscription

All Implemented Interfaces:

Cancellable, PublisherSource.Subscription

public final class DelayedSubscription
extends Object
implements PublisherSource.Subscription

A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.

Field Summary

Fields inherited from interface io.servicetalk.concurrent.Cancellable

IGNORE_CANCEL

Constructor Summary

Constructors

Constructor	Description
DelayedSubscription()

Method Summary

Modifier and Type	Method	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	delayedSubscription(PublisherSource.Subscription delayedSubscription)	Set the delayed PublisherSource.Subscription.
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

Constructor Details

DelayedSubscription

public DelayedSubscription()

Method Details

delayedSubscription

public void delayedSubscription(PublisherSource.Subscription delayedSubscription)

Set the delayed PublisherSource.Subscription. This method can only be called a single time and subsequent calls will result in cancel() being called on delayedSubscription.

Parameters:

delayedSubscription - The delayed PublisherSource.Subscription.

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