public interface Subscription
Subscriptionrepresents a one-to-one lifecycle of a
Observersubscribing to an
Instances can only be used once by a single
It is used to both signal desire for data and to allow for unsubscribing.
|Modifier and Type||Method||Description|
Indicates whether this
No operation will be sent to MongoDB from the
void request(long n)
Observableuntil demand is signaled via this method.
It can be called however often and whenever needed, but the outstanding cumulative demand must never exceed
An outstanding cumulative demand of
Long.MAX_VALUE may be treated by the
Observable as "effectively unbounded".
Whatever has been requested might be sent, so only signal demand for what can be safely handled.
Observable can send less than is requested if the stream ends but then must emit either
n- the strictly positive number of elements to requests to the upstream
Observableto stop sending data and clean up resources.
As this request is asynchronous data may still be sent to meet previously signalled demand after calling cancel.
Subscriptionis currently unsubscribed.
Subscriptionis currently unsubscribed,