File tree Expand file tree Collapse file tree 2 files changed +19
-7
lines changed Expand file tree Collapse file tree 2 files changed +19
-7
lines changed Original file line number Diff line number Diff line change @@ -23,10 +23,16 @@ public interface Producer {
23
23
/**
24
24
* Request a certain maximum number of items from this Producer. This is a way of requesting backpressure.
25
25
* To disable backpressure, pass {@code Long.MAX_VALUE} to this method.
26
- * <p>
27
- * Requests are additive but if the total requests overflows {@code Long.MAX_VALUE} then the total requests
28
- * is set to {@code Long.MAX_VALUE}. Arriving at {@code Long.MAX_VALUE} by addition of requests cannot be
29
- * assumed to disable backpressure.
26
+ * * <p>
27
+ * Requests are additive but if a sequence of requests totals more than {@code Long.MAX_VALUE} then
28
+ * {@code Long.MAX_VALUE} requests will be actioned and the extras <i>may</i> be ignored. Arriving at
29
+ * {@code Long.MAX_VALUE} by addition of requests cannot be assumed to disable backpressure. For example,
30
+ * the code below may result in {@code Long.MAX_VALUE} requests being actioned only.
31
+ *
32
+ * <pre>
33
+ * request(100);
34
+ * request(Long.MAX_VALUE-1);
35
+ * </pre>
30
36
*
31
37
* @param n the maximum number of items you want this Producer to produce, or {@code Long.MAX_VALUE} if you
32
38
* want the Producer to produce items at its own pace
Original file line number Diff line number Diff line change @@ -90,9 +90,15 @@ public void onStart() {
90
90
* This is a way of requesting backpressure. To disable backpressure, pass {@code Long.MAX_VALUE} to this
91
91
* method.
92
92
* <p>
93
- * Requests are additive but if the total requests overflows {@code Long.MAX_VALUE} then the total requests
94
- * is set to {@code Long.MAX_VALUE}. Arriving at {@code Long.MAX_VALUE} by addition of requests cannot be
95
- * assumed to disable backpressure.
93
+ * Requests are additive but if a sequence of requests totals more than {@code Long.MAX_VALUE} then
94
+ * {@code Long.MAX_VALUE} requests will be actioned and the extras <i>may</i> be ignored. Arriving at
95
+ * {@code Long.MAX_VALUE} by addition of requests cannot be assumed to disable backpressure. For example,
96
+ * the code below may result in {@code Long.MAX_VALUE} requests being actioned only.
97
+ *
98
+ * <pre>
99
+ * request(100);
100
+ * request(Long.MAX_VALUE-1);
101
+ * </pre>
96
102
*
97
103
* @param n the maximum number of items you want the Observable to emit to the Subscriber at this time, or
98
104
* {@code Long.MAX_VALUE} if you want the Observable to emit items at its own pace
You can’t perform that action at this time.
0 commit comments