@@ -5056,7 +5056,7 @@ public final Observable<T> onBackpressureDrop() {
5056
5056
}
5057
5057
5058
5058
/**
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
5060
5060
* block the producer thread.
5061
5061
* <p>
5062
5062
* The producer side can emit up to {@code maxQueueLength} onNext elements without blocking, but the
@@ -5071,17 +5071,18 @@ public final Observable<T> onBackpressureDrop() {
5071
5071
* @return the source Observable modified to block {@code onNext} notifications on overflow
5072
5072
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5073
5073
* @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)
5074
5075
*/
5075
5076
@ Experimental
5076
5077
public final Observable <T > onBackpressureBlock (int maxQueueLength ) {
5077
5078
return lift (new OperatorOnBackpressureBlock <T >(maxQueueLength ));
5078
5079
}
5079
5080
/**
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.
5082
5083
* <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)}
5085
5086
* and doesn't emit more than requested even if available.
5086
5087
* <p>
5087
5088
* 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) {
5090
5091
* @return the source Observable modified to block {@code onNext} notifications on overflow
5091
5092
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5092
5093
* @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)
5093
5095
*/
5094
5096
@ Experimental
5095
5097
public final Observable <T > onBackpressureBlock () {
0 commit comments