@@ -5037,40 +5037,42 @@ public final Observable<T> onBackpressureBuffer() {
5037
5037
}
5038
5038
5039
5039
/**
5040
- * Instructs an Observable that is emitting items faster than its observer can consume them to buffer
5041
- * up to a given amount of items until they can be emitted. The resulting Observable will {@code onError} emitting a
5042
- * {@link java.nio. BufferOverflowException} as soon as the buffer's capacity is exceeded, dropping all
5043
- * undelivered items, and unsubscribing from the source.
5040
+ * Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
5041
+ * a given amount of items until they can be emitted. The resulting Observable will {@code onError} emitting
5042
+ * a {@code BufferOverflowException} as soon as the buffer's capacity is exceeded, dropping all undelivered
5043
+ * items, and unsubscribing from the source.
5044
5044
* <p>
5045
5045
* <img width="640" height="300" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.buffer.png" alt="">
5046
5046
* <dl>
5047
5047
* <dt><b>Scheduler:</b></dt>
5048
5048
* <dd>{@code onBackpressureBuffer} does not operate by default on a particular {@link Scheduler}.</dd>
5049
5049
* </dl>
5050
5050
*
5051
- * @return the source Observable modified to buffer items up to the given capacity.
5051
+ * @return the source Observable modified to buffer items up to the given capacity
5052
5052
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5053
5053
* @Beta
5054
+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5054
5055
*/
5055
5056
@ Beta
5056
5057
public final Observable <T > onBackpressureBuffer (long capacity ) {
5057
5058
return lift (new OperatorOnBackpressureBuffer <T >(capacity ));
5058
5059
}
5059
5060
5060
5061
/**
5061
- * Instructs an Observable that is emitting items faster than its observer can consume them to buffer
5062
- * up to a given amount of items until they can be emitted. The resulting Observable will {@code onError} emitting a
5063
- * {@link java.nio. BufferOverflowException} as soon as the buffer's capacity is exceeded, dropping all
5064
- * undelivered items, unsubscribing from the source, and notifying the producer with {@code onOverflow}.
5062
+ * Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
5063
+ * a given amount of items until they can be emitted. The resulting Observable will {@code onError} emitting
5064
+ * a {@code BufferOverflowException} as soon as the buffer's capacity is exceeded, dropping all undelivered
5065
+ * items, unsubscribing from the source, and notifying the producer with {@code onOverflow}.
5065
5066
* <p>
5066
5067
* <img width="640" height="300" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.buffer.png" alt="">
5067
5068
* <dl>
5068
5069
* <dt><b>Scheduler:</b></dt>
5069
5070
* <dd>{@code onBackpressureBuffer} does not operate by default on a particular {@link Scheduler}.</dd>
5070
5071
* </dl>
5071
5072
*
5072
- * @return the source Observable modified to buffer items up to the given capacity.
5073
+ * @return the source Observable modified to buffer items up to the given capacity
5073
5074
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5075
+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5074
5076
* @Beta
5075
5077
*/
5076
5078
@ Beta
0 commit comments