@@ -5056,7 +5056,7 @@ public final Observable<T> onBackpressureDrop() {
50565056 }
50575057
50585058 /**
5059- * Instructs an Observable that is emitting items faster than its observer can consume them is to
5059+ * Instructs an Observable that is emitting items faster than its observer can consume them to
50605060 * block the producer thread.
50615061 * <p>
50625062 * The producer side can emit up to {@code maxQueueLength} onNext elements without blocking, but the
@@ -5071,17 +5071,18 @@ public final Observable<T> onBackpressureDrop() {
50715071 * @return the source Observable modified to block {@code onNext} notifications on overflow
50725072 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
50735073 * @Experimental The behavior of this can change at any time.
5074+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
50745075 */
50755076 @ Experimental
50765077 public final Observable <T > onBackpressureBlock (int maxQueueLength ) {
50775078 return lift (new OperatorOnBackpressureBlock <T >(maxQueueLength ));
50785079 }
50795080 /**
5080- * Instructs an Observable that is emitting items faster than its observer can consume them is to
5081- * block the producer thread if the number of undelivered onNext events reaches the system-wide ring buffer size.
5081+ * Instructs an Observable that is emitting items faster than its observer can consume them to block the
5082+ * producer thread if the number of undelivered onNext events reaches the system-wide ring buffer size.
50825083 * <p>
5083- * The producer side can emit up to the system-wide ring buffer size onNext elements without blocking, but the
5084- * consumer side considers the amount its downstream requested through {@code Producer.request(n)}
5084+ * The producer side can emit up to the system-wide ring buffer size onNext elements without blocking, but
5085+ * the consumer side considers the amount its downstream requested through {@code Producer.request(n)}
50855086 * and doesn't emit more than requested even if available.
50865087 * <p>
50875088 * Note that if the upstream Observable does support backpressure, this operator ignores that capability
@@ -5090,6 +5091,7 @@ public final Observable<T> onBackpressureBlock(int maxQueueLength) {
50905091 * @return the source Observable modified to block {@code onNext} notifications on overflow
50915092 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
50925093 * @Experimental The behavior of this can change at any time.
5094+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
50935095 */
50945096 @ Experimental
50955097 public final Observable <T > onBackpressureBlock () {
0 commit comments