OperatorAll & Backpressure

Similar to filter, it needs to request(1) each time it filters an onNext.

Author: benjchristensen

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

@@ -45,6 +45,9 @@ public void onNext(T t) {
                     child.onNext(false);
                     child.onCompleted();
                     unsubscribe();
+                } else {
+                	// if we drop values we must replace them upstream as downstream won't receive and request more
+                	request(1);
                 }
             }