Correct static access warnings

Author: gliptak

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

@@ -185,7 +185,7 @@ private void handleScalarSynchronousObservableWithRequestLimits(ScalarSynchronou
                     if (r > 0) {
                         emitted = true;
                         actual.onNext(t.get());
-                        mergeProducer.REQUESTED.decrementAndGet(mergeProducer);
+                        MergeProducer.REQUESTED.decrementAndGet(mergeProducer);
                         // we handle this Observable without ever incrementing the wip or touching other machinery so just return here
                         return;
                     }
@@ -295,7 +295,7 @@ private int drainScalarValueQueue() {
                         }
                     }
                     // decrement the number we emitted from outstanding requests
-                    mergeProducer.REQUESTED.getAndAdd(mergeProducer, -emittedWhileDraining);
+                    MergeProducer.REQUESTED.getAndAdd(mergeProducer, -emittedWhileDraining);
                 }
                 return emittedWhileDraining;
             }
@@ -500,7 +500,7 @@ private void emit(T t, boolean complete) {
                             } else {
                                 parentSubscriber.actual.onNext(t);
                                 emitted++;
-                                producer.REQUESTED.decrementAndGet(producer);
+                                MergeProducer.REQUESTED.decrementAndGet(producer);
                             }
                         } else {
                             // no requests available, so enqueue it
@@ -587,7 +587,7 @@ private int drainRequested() {
             }
 
             // decrement the number we emitted from outstanding requests
-            producer.REQUESTED.getAndAdd(producer, -emitted);
+            MergeProducer.REQUESTED.getAndAdd(producer, -emitted);
             return emitted;
         }