@@ -4161,7 +4161,8 @@ public final void onNext(T args) {
4161
4161
}
4162
4162
4163
4163
/**
4164
- * Modifies the source {@code Observable} so that it invokes the given action when it receives a request for more items.
4164
+ * Modifies the source {@code Observable} so that it invokes the given action when it receives a request for
4165
+ * more items.
4165
4166
* <dl>
4166
4167
* <dt><b>Scheduler:</b></dt>
4167
4168
* <dd>{@code doOnRequest} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -4170,6 +4171,7 @@ public final void onNext(T args) {
4170
4171
* @param onRequest
4171
4172
* the action that gets called when an observer requests items from this {@code Observable}
4172
4173
* @return the source {@code Observable} modified so as to call this Action when appropriate
4174
+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
4173
4175
*/
4174
4176
@ Beta
4175
4177
public final Observable <T > doOnRequest (final Action1 <Long > onRequest ) {
@@ -5066,7 +5068,6 @@ public final Observable<T> onBackpressureBuffer() {
5066
5068
*
5067
5069
* @return the source Observable modified to buffer items up to the given capacity
5068
5070
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5069
- * @Beta
5070
5071
* @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5071
5072
*/
5072
5073
@ Beta
@@ -5089,7 +5090,6 @@ public final Observable<T> onBackpressureBuffer(long capacity) {
5089
5090
* @return the source Observable modified to buffer items up to the given capacity
5090
5091
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5091
5092
* @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5092
- * @Beta
5093
5093
*/
5094
5094
@ Beta
5095
5095
public final Observable <T > onBackpressureBuffer (long capacity , Action0 onOverflow ) {
0 commit comments