File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -349,9 +349,10 @@ public void onNext(Object t) {
349
349
// now when there is the possibility that the child may unsubscribe and never use
350
350
// that resubscription
351
351
352
- //TODO what if consumerCapacity increases now then we are in a situation where the
353
- // next call of request(n) will do nothing because of the c ==0 check in request(n).
354
- // this could cause the stream to stall? Fix might be to remove c==0 check?
352
+ // TODO what if consumerCapacity increases now then we are in a situation where the
353
+ // next call of request(n) will not initiate a new subscription because of the c ==0
354
+ // check in request(n). This could cause the stream to stall? Fix might be to remove
355
+ // c==0 check?
355
356
resumeBoundary .compareAndSet (false , true );
356
357
}
357
358
}
You can’t perform that action at this time.
0 commit comments