Fix for #2869 overlapping windows. Source was emitting t multiple tim…

…es while holding queue.
ReactiveX · Apr 20, 2015 · 535c41b · 535c41b
1 parent 9d90aed
commit 535c41b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/rx/internal/operators/OperatorWindowWithObservable.java b/src/main/java/rx/internal/operators/OperatorWindowWithObservable.java
@@ -119,7 +119,7 @@ public void onNext(T t) {
                 do {
                     drain(localQueue);
                     if (once) {
-                        once = true;
+                        once = false;
                         emitValue(t);
                     }