Merge pull request #1453 from spodila/takeWhileFailure

New test case for takeWhile that currently fails
ReactiveX · Jul 17, 2014 · cb20468 · cb20468
2 parents 877ee89 + ce6a6fb
commit cb20468
Showing 1 changed file with 25 additions and 0 deletions.
diff --git a/rxjava-core/src/test/java/rx/ObservableTests.java b/rxjava-core/src/test/java/rx/ObservableTests.java
@@ -1027,4 +1027,29 @@ public Observable<String> call(String s) {
         });
         o.subscribe();
     }
+
+    @Test
+    public void testTakeWhileToList() {
+        int[] nums = {1, 2, 3};
+        final AtomicInteger count = new AtomicInteger();
+        for(final int n: nums) {
+            Observable
+                    .from(Boolean.TRUE, Boolean.FALSE)
+                    .takeWhile(new Func1<Boolean, Boolean>() {
+                        @Override
+                        public Boolean call(Boolean value) {
+                            return value;
+                        }
+                    })
+                    .toList()
+                    .doOnNext(new Action1<List<Boolean>>() {
+                        @Override
+                        public void call(List<Boolean> booleans) {
+                            count.incrementAndGet();
+                        }
+                    })
+                    .subscribe();
+        }
+        assertEquals(nums.length, count.get());
+    }
 }