File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -351,8 +351,8 @@ public void onNext(Object t) {
351
351
// that resubscription
352
352
353
353
//TODO what if consumerCapacity increases now then we are in a situation where the
354
- // next call of request(n) will do nothing because of the c ==0 check in request(n)
355
- // this would cause the stream to stall?
354
+ // next call of request(n) will do nothing because of the c ==0 check in request(n).
355
+ // this could cause the stream to stall? Fix might be to remove c==0 check ?
356
356
resumeBoundary .compareAndSet (false , true );
357
357
}
358
358
}
@@ -378,7 +378,7 @@ public void request(final long n) {
378
378
if (producer != null ) {
379
379
// TODO what if at this point the subscription finishes and currentProducer
380
380
// is set to null or even the next producer. The request would be added to consumerCapacity but
381
- // if it more requests only come after emission then this call to the old producer could produce
381
+ // if more requests only come after emission then this call to the old producer could produce
382
382
// nothing and the stream would stall
383
383
producer .request (n );
384
384
} else
You can’t perform that action at this time.
0 commit comments