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 08bf50f commit 334de61Copy full SHA for 334de61
rxjava-core/src/main/java/rx/internal/operators/OperatorMerge.java
@@ -210,7 +210,7 @@ private void handleScalarSynchronousObservable(ScalarSynchronousObservable<? ext
210
* } </pre>
211
*
212
*/
213
- if (mergeProducer.requested < 0) {
+ if (mergeProducer.requested == Long.MAX_VALUE) {
214
handleScalarSynchronousObservableWithoutRequestLimits(t);
215
} else {
216
handleScalarSynchronousObservableWithRequestLimits(t);
@@ -489,6 +489,9 @@ public MergeProducer(MergeSubscriber<T> ms) {
489
490
@Override
491
public void request(long n) {
492
+ if (requested == Long.MAX_VALUE) {
493
+ return;
494
+ }
495
if (n == Long.MAX_VALUE) {
496
requested = Long.MAX_VALUE;
497
0 commit comments