Package io.servicetalk.concurrent
Interface PublisherSource.Subscription
-
- All Superinterfaces:
Cancellable
- All Known Implementing Classes:
ConcurrentSubscription
,DeferredEmptySubscription
,DelayedSubscription
,EmptySubscription
,ScalarValueSubscription
,TestSubscription
- Enclosing interface:
- PublisherSource<T>
public static interface PublisherSource.Subscription extends Cancellable
A subscription to control the signals emitted from aPublisherSource
to aPublisherSource.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 StreamsSubscription
in Section 3 of the specifications.
-
-
Field Summary
-
Fields inherited from interface io.servicetalk.concurrent.Cancellable
IGNORE_CANCEL
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
request(long n)
Requestsn
more items from the associatedPublisherSource
for the associatedPublisherSource.Subscriber
.-
Methods inherited from interface io.servicetalk.concurrent.Cancellable
cancel
-
-
-
-
Method Detail
-
request
void request(long n)
Requestsn
more items from the associatedPublisherSource
for the associatedPublisherSource.Subscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Parameters:
n
- Number of items to request.
-
-