Package io.servicetalk.concurrent.internal

Class ConcurrentSubscription

java.lang.Object

io.servicetalk.concurrent.internal.ConcurrentSubscription

All Implemented Interfaces:

Cancellable, PublisherSource.Subscription

public class ConcurrentSubscription
extends Object
implements PublisherSource.Subscription

This class prevents concurrent invocation of PublisherSource.Subscription methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.

Field Summary

Fields inherited from interface io.servicetalk.concurrent.Cancellable

IGNORE_CANCEL

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConcurrentSubscription(PublisherSource.Subscription subscription)	New instance.

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	request(long n)	Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.
static ConcurrentSubscription	wrap(PublisherSource.Subscription subscription)	Wrap a PublisherSource.Subscription to make it thread safe when concurrent access may exists between PublisherSource.Subscription.request(long) and Cancellable.cancel().

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentSubscription

protected ConcurrentSubscription(PublisherSource.Subscription subscription)

New instance.

Parameters:

subscription - PublisherSource.Subscription to wrap.

Method Details

wrap

public static ConcurrentSubscription wrap(PublisherSource.Subscription subscription)

Wrap a PublisherSource.Subscription to make it thread safe when concurrent access may exists between PublisherSource.Subscription.request(long) and Cancellable.cancel().

Parameters:

subscription - The subscription to wrap.

Returns:

A PublisherSource.Subscription that will enforce the threading constraints in a concurrent environment.

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