Skip to content

Commit 535c41b

Browse files
author
Alex Wenckus
committed
Fix for #2869 overlapping windows. Source was emitting t multiple times while holding queue.
1 parent 9d90aed commit 535c41b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/rx/internal/operators/OperatorWindowWithObservable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ public void onNext(T t) {
119119
do {
120120
drain(localQueue);
121121
if (once) {
122-
once = true;
122+
once = false;
123123
emitValue(t);
124124
}
125125

0 commit comments

Comments
 (0)