Merge pull request ReactiveX#1530 from zsxwing/issue-merge

Fix the unbounded check for merge

Author: benjchristensen

rxjava-core/src/main/java/rx/internal/operators/OperatorMerge.java

@@ -210,7 +210,7 @@ private void handleScalarSynchronousObservable(ScalarSynchronousObservable<? ext
              * } </pre>
              * 
              */
-            if (mergeProducer.requested < 0) {
+            if (mergeProducer.requested == Long.MAX_VALUE) {
                 handleScalarSynchronousObservableWithoutRequestLimits(t);
             } else {
                 handleScalarSynchronousObservableWithRequestLimits(t);
@@ -489,6 +489,9 @@ public MergeProducer(MergeSubscriber<T> ms) {
 
         @Override
         public void request(long n) {
+            if (requested == Long.MAX_VALUE) {
+                return;
+            }
             if (n == Long.MAX_VALUE) {
                 requested = Long.MAX_VALUE;
             } else {