File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -5370,15 +5370,18 @@ public final Observable<T> onBackpressureBlock() {
5370
5370
* Instructs an Observable that is emitting items faster than its observer can consume them to
5371
5371
* hold onto the latest value and emit that on request.
5372
5372
* <p>
5373
- * Its behavior is logically equivalent to toBlocking().latest() with the exception that
5373
+ * <img width="640" height="245" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.latest.png" alt="">
5374
+ * <p>
5375
+ * Its behavior is logically equivalent to {@code toBlocking().latest()} with the exception that
5374
5376
* the downstream is not blocking while requesting more values.
5375
5377
* <p>
5376
5378
* Note that if the upstream Observable does support backpressure, this operator ignores that capability
5377
5379
* and doesn't propagate any backpressure requests from downstream.
5378
5380
* <p>
5379
5381
* Note that due to the nature of how backpressure requests are propagated through subscribeOn/observeOn,
5380
5382
* requesting more than 1 from downstream doesn't guarantee a continuous delivery of onNext events.
5381
- * @return
5383
+ *
5384
+ * @return the source Observable modified so that it emits the most recently-received item upon request
5382
5385
* @Experimental The behavior of this can change at any time.
5383
5386
* @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
5384
5387
*/
You can’t perform that action at this time.
0 commit comments