File tree Expand file tree Collapse file tree 1 file changed +14
-8
lines changed Expand file tree Collapse file tree 1 file changed +14
-8
lines changed Original file line number Diff line number Diff line change @@ -4444,20 +4444,26 @@ public final void onNext(T args) {
4444
4444
4445
4445
return lift (new OperatorDoOnEach <T >(observer ));
4446
4446
}
4447
-
4447
+
4448
4448
/**
4449
- * Modifies the source {@code Observable} so that it invokes the given action when it receives a request for
4450
- * more items.
4449
+ * Modifies the source {@code Observable} so that it invokes the given action when it receives a
4450
+ * request for more items.
4451
+ * <p>
4452
+ * <b>Note:</b> This operator is for tracing the internal behavior of back-pressure request
4453
+ * patterns and generally intended for debugging use.
4451
4454
* <dl>
4452
- * <dt><b>Scheduler:</b></dt>
4453
- * <dd>{@code doOnRequest} does not operate by default on a particular {@link Scheduler}.</dd>
4455
+ * <dt><b>Scheduler:</b></dt>
4456
+ * <dd>{@code doOnRequest} does not operate by default on a particular {@link Scheduler}.</dd>
4454
4457
* </dl>
4455
4458
*
4456
4459
* @param onRequest
4457
- * the action that gets called when an observer requests items from this {@code Observable}
4460
+ * the action that gets called when an observer requests items from this
4461
+ * {@code Observable}
4458
4462
* @return the source {@code Observable} modified so as to call this Action when appropriate
4459
- * @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>
4460
- * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
4463
+ * @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators
4464
+ * documentation: Do</a>
4465
+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical
4466
+ * with the release number)
4461
4467
*/
4462
4468
@ Beta
4463
4469
public final Observable <T > doOnRequest (final Action1 <Long > onRequest ) {
You can’t perform that action at this time.
0 commit comments