We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7c23049 commit 838435cCopy full SHA for 838435c
src/main/java/rx/internal/operators/OnSubscribeRedo.java
@@ -375,7 +375,7 @@ public void request(final long n) {
375
// producer will call setProducer and request with consumerCapacity on the new producer.
376
producer.request(n);
377
} else
378
- if (resumeBoundary.compareAndSet(true, false)) {
+ if (c==0 && resumeBoundary.compareAndSet(true, false)) {
379
worker.schedule(subscribeToSource);
380
}
381
0 commit comments