Skip to content

Commit 68a356e

Browse files
committed
Changed javadoc regarding backpressure
1 parent c698a61 commit 68a356e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/main/java/rx/Observable.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8896,7 +8896,8 @@ public final <TClosing> Observable<Observable<T>> window(Func0<? extends Observa
88968896
* <img width="640" height="400" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window3.png" alt="">
88978897
* <dl>
88988898
* <dt><b>Backpressure Support:</b></dt>
8899-
* <dd>This operator does not support backpressure as it uses {@code count} to control data flow.</dd>
8899+
* <dd>The operator honors backpressure on its outer subscriber, ignores backpressure in its inner Observables
8900+
* but each of them will emit at most {@code count} elements.</dd>
89008901
* <dt><b>Scheduler:</b></dt>
89018902
* <dd>This version of {@code window} does not operate by default on a particular {@link Scheduler}.</dd>
89028903
* </dl>
@@ -8920,7 +8921,8 @@ public final Observable<Observable<T>> window(int count) {
89208921
* <img width="640" height="365" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/window4.png" alt="">
89218922
* <dl>
89228923
* <dt><b>Backpressure Support:</b></dt>
8923-
* <dd>This operator does not support backpressure as it uses {@code count} to control data flow.</dd>
8924+
* <dd>The operator has limited backpressure support. If {@code count} == {@code skip}, the operator honors backpressure on its outer subscriber, ignores backpressure in its inner Observables
8925+
* but each of them will emit at most {@code count} elements.</dd>
89248926
* <dt><b>Scheduler:</b></dt>
89258927
* <dd>This version of {@code window} does not operate by default on a particular {@link Scheduler}.</dd>
89268928
* </dl>

0 commit comments

Comments
 (0)