Add test of backpressure to OperatorAll

Author: mattrjacobs

rxjava-core/src/test/java/rx/internal/operators/OperatorAllTest.java

@@ -15,6 +15,7 @@
  */
 package rx.internal.operators;
 
+import static org.junit.Assert.assertFalse;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.verifyNoMoreInteractions;
@@ -25,6 +26,8 @@
 import rx.Observer;
 import rx.functions.Func1;
 
+import java.util.Arrays;
+
 public class OperatorAllTest {
 
     @Test
@@ -98,4 +101,16 @@ public Boolean call(String s) {
         verify(observer).onError(error);
         verifyNoMoreInteractions(observer);
     }
+
+    @Test
+    public void testFollowingFirst() {
+        Observable<Integer> o = Observable.from(Arrays.asList(1, 3, 5, 6));
+        Observable<Boolean> allOdd = o.all(new Func1<Integer, Boolean>() {
+            @Override
+            public Boolean call(Integer i) {
+                return i % 2 == 1;
+            }
+        });
+        assertFalse(allOdd.toBlocking().first());
+    }
 }