Support OnSetProducer/Request Changes

Author: benjchristensen

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

@@ -276,7 +276,7 @@ void tick() {
                             }
                             if (emitted > THRESHOLD) {
                                 for (Object obj : observers) {
-                                    ((InnerSubscriber) obj).request(emitted);
+                                    ((InnerSubscriber) obj).requestMore(emitted);
                                 }
                                 emitted = 0;
                             }
@@ -298,6 +298,10 @@ final class InnerSubscriber extends Subscriber {
             public void onStart() {
                 request(RxRingBuffer.SIZE);
             }
+            
+            public void requestMore(long n) {
+                request(n);
+            }
 
             @SuppressWarnings("unchecked")
             @Override