@@ -4161,7 +4161,8 @@ public final void onNext(T args) {
41614161 }
41624162
41634163 /**
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.
41654166 * <dl>
41664167 * <dt><b>Scheduler:</b></dt>
41674168 * <dd>{@code doOnRequest} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -4170,6 +4171,7 @@ public final void onNext(T args) {
41704171 * @param onRequest
41714172 * the action that gets called when an observer requests items from this {@code Observable}
41724173 * @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)
41734175 */
41744176 @ Beta
41754177 public final Observable <T > doOnRequest (final Action1 <Long > onRequest ) {
@@ -5066,7 +5068,6 @@ public final Observable<T> onBackpressureBuffer() {
50665068 *
50675069 * @return the source Observable modified to buffer items up to the given capacity
50685070 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5069- * @Beta
50705071 * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
50715072 */
50725073 @ Beta
@@ -5089,7 +5090,6 @@ public final Observable<T> onBackpressureBuffer(long capacity) {
50895090 * @return the source Observable modified to buffer items up to the given capacity
50905091 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
50915092 * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5092- * @Beta
50935093 */
50945094 @ Beta
50955095 public final Observable <T > onBackpressureBuffer (long capacity , Action0 onOverflow ) {
0 commit comments