diff --git a/rxjava-core/src/test/java/rx/ObservableTests.java b/rxjava-core/src/test/java/rx/ObservableTests.java index a983d7fc8b..72fb2bb505 100644 --- a/rxjava-core/src/test/java/rx/ObservableTests.java +++ b/rxjava-core/src/test/java/rx/ObservableTests.java @@ -1027,4 +1027,29 @@ public Observable 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() { + @Override + public Boolean call(Boolean value) { + return value; + } + }) + .toList() + .doOnNext(new Action1>() { + @Override + public void call(List booleans) { + count.incrementAndGet(); + } + }) + .subscribe(); + } + assertEquals(nums.length, count.get()); + } }