public interface Producer
The request amount only affects calls to
Observer.onNext(Object); onError and onCompleted may appear without
However, backpressure is somewhat optional in RxJava 1.x and Subscribers may not
receive a Producer via their
Subscriber.setProducer(Producer) method and will run
in unbounded mode. Depending on the chain of operators, this can lead to
|Modifier and Type||Method and Description|
Request a certain maximum number of items from this Producer.
void request(long n)
Long.MAX_VALUEto this method.
Requests are additive but if a sequence of requests totals more than
Long.MAX_VALUE requests will be actioned and the extras may be ignored. Arriving at
Long.MAX_VALUE by addition of requests cannot be assumed to disable backpressure. For example,
the code below may result in
Long.MAX_VALUE requests being actioned only.
n- the maximum number of items you want this Producer to produce, or
Long.MAX_VALUEif you want the Producer to produce items at its own pace
java.lang.IllegalArgumentException- if the request amount is negative