File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -5059,6 +5059,8 @@ public final Observable<T> onBackpressureDrop() {
5059
5059
* Instructs an Observable that is emitting items faster than its observer can consume them to
5060
5060
* block the producer thread.
5061
5061
* <p>
5062
+ * <img width="640" height="245" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.block.png" alt="">
5063
+ * <p>
5062
5064
* The producer side can emit up to {@code maxQueueLength} onNext elements without blocking, but the
5063
5065
* consumer side considers the amount its downstream requested through {@code Producer.request(n)}
5064
5066
* and doesn't emit more than requested even if more is available. For example, using
@@ -5081,6 +5083,8 @@ public final Observable<T> onBackpressureBlock(int maxQueueLength) {
5081
5083
* Instructs an Observable that is emitting items faster than its observer can consume them to block the
5082
5084
* producer thread if the number of undelivered onNext events reaches the system-wide ring buffer size.
5083
5085
* <p>
5086
+ * <img width="640" height="245" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.block.png" alt="">
5087
+ * <p>
5084
5088
* The producer side can emit up to the system-wide ring buffer size onNext elements without blocking, but
5085
5089
* the consumer side considers the amount its downstream requested through {@code Producer.request(n)}
5086
5090
* and doesn't emit more than requested even if available.
You can’t perform that action at this time.
0 commit comments