Package io.servicetalk.concurrent
Interface PublisherSource.Subscription
-
- All Superinterfaces:
Cancellable
- All Known Implementing Classes:
ConcurrentSubscription,DeferredEmptySubscription,DelayedSubscription,ScalarValueSubscription,TestSubscription
- Enclosing interface:
- PublisherSource<T>
public static interface PublisherSource.Subscription extends Cancellable
A subscription to control the signals emitted from aPublisherSourceto aPublisherSource.Subscriber.This is a replica of the APIs provided by Reactive Streams and follows the Reactive Streams specifications. All implementations of this
Subscriptionadhere to the rules as specified for a Reactive StreamsSubscriptionin 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 voidrequest(long n)Requestsnmore items from the associatedPublisherSourcefor the associatedPublisherSource.Subscriber.-
Methods inherited from interface io.servicetalk.concurrent.Cancellable
cancel
-
-
-
-
Method Detail
-
request
void request(long n)
Requestsnmore items from the associatedPublisherSourcefor 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.
-
-