Skip to content

Commit 1dfcbf6

Browse files
committed
clean up onBackpressureDrop() javadocs and make similar to those for onBackpressureBuffer() (#1854)
1 parent 6a34999 commit 1dfcbf6

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/rx/Observable.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5159,13 +5159,13 @@ public final Observable<T> onBackpressureBuffer() {
51595159
}
51605160

51615161
/**
5162-
* Use this operator when the upstream does not natively support backpressure and you wish to drop
5163-
* {@code onNext} when unable to handle further events.
5162+
* Instructs an Observable that is emitting items faster than its observer can consume them to discard,
5163+
* rather than emit, those items that its observer is not prepared to observe.
51645164
* <p>
51655165
* <img width="640" height="245" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/bp.obp.drop.png" alt="">
51665166
* <p>
5167-
* If the downstream request count hits 0 then {@code onNext} will be dropped until {@code request(long n)}
5168-
* is invoked again to increase the request count.
5167+
* If the downstream request count hits 0 then the Observable will refrain from calling {@code onNext} until
5168+
* the observer invokes {@code request(n)} again to increase the request count.
51695169
* <dl>
51705170
* <dt><b>Scheduler:</b></dt>
51715171
* <dd>{@code onBackpressureDrop} does not operate by default on a particular {@link Scheduler}.</dd>

0 commit comments

Comments
 (0)