Merge pull request #1469 from mattrjacobs/fix-tolist-backpressure

ToList operator needs to ignore backpressure

Author: mattrjacobs

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

@@ -44,6 +44,11 @@ public Subscriber<? super T> call(final Subscriber<? super List<T>> o) {
 
             final List<T> list = new LinkedList<T>();
 
+            @Override
+            public void onStart() {
+                request(Long.MAX_VALUE);
+            }
+
             @Override
             public void onCompleted() {
                 try {

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

@@ -23,6 +23,7 @@
 import java.util.Arrays;
 import java.util.List;
 
+import org.junit.Assert;
 import org.junit.Test;
 import org.mockito.Mockito;
 
@@ -94,4 +95,11 @@ public void testListWithNullValue() {
         verify(observer, Mockito.never()).onError(any(Throwable.class));
         verify(observer, times(1)).onCompleted();
     }
+
+    @Test
+    public void testListWithBlockingFirst() {
+        Observable<String> o = Observable.from(Arrays.asList("one", "two", "three"));
+        List<String> actual = o.toList().toBlocking().first();
+        Assert.assertEquals(Arrays.asList("one", "two", "three"), actual);
+    }
 }