public interface Subscription
Subscription
represents a one-to-one lifecycle of a Subscriber
subscribing to a Publisher
.
It can only be used once by a single Subscriber
.
It is used to both signal desire for data and cancel demand (and allow resource cleanup).
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Request the
Publisher to stop sending data and clean up resources. |
void |
request(int n)
No events will be sent by a
Publisher until demand is signaled via this method. |
void request(int n)
Publisher
until demand is signaled via this method.
It can be called however often and whenever needed.
Whatever has been requested can be sent by the Publisher
so only signal demand for what can be safely handled.
A Publisher
can send less than is requested if the stream ends but
then must emit either Subscriber.onError(Throwable)
or Subscriber.onComplete()
.
n
- the strictly positive number of elements to requests to the upstream Publisher
void cancel()
Publisher
to stop sending data and clean up resources.
Data may still be sent to meet previously signalled demand after calling cancel as this request is asynchronous.
Copyright © 2016. All rights reserved.