Package io.servicetalk.concurrent

Interface PublisherSource.Subscription

All Superinterfaces:

Cancellable

All Known Implementing Classes:

ConcurrentSubscription, DelayedSubscription, ScalarValueSubscription

Enclosing interface:

PublisherSource<T>

public static interface PublisherSource.Subscription
extends Cancellable

A subscription to control the signals emitted from a PublisherSource to a PublisherSource.Subscriber.

This is a replica of the APIs provided by Reactive Streams and follows the Reactive Streams specifications. All implementations of this Subscription adhere to the rules as specified for a Reactive Streams Subscription in Section 3 of the specifications.

Field Summary

Fields inherited from interface io.servicetalk.concurrent.Cancellable

IGNORE_CANCEL

Method Summary

Modifier and Type	Method	Description
void	request(long n)	Requests n more items from the associated PublisherSource for the associated PublisherSource.Subscriber.

Methods inherited from interface io.servicetalk.concurrent.Cancellable

cancel

Method Details

request

void request(long n)

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.

Parameters:

n - Number of items to request.