Merge pull request #1474 from mattrjacobs/ignore-backpressure-operator-tosortedlist

Ignore backpressure for OperatorToObservableSortedList

Author: mattrjacobs

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

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

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

@@ -15,6 +15,7 @@
  */
 package rx.internal.operators;
 
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
@@ -65,4 +66,10 @@ public Integer call(Integer t1, Integer t2) {
         verify(observer, Mockito.never()).onError(any(Throwable.class));
         verify(observer, times(1)).onCompleted();
     }
+
+    @Test
+    public void testWithFollowingFirst() {
+        Observable<Integer> o = Observable.from(1, 3, 2, 5, 4);
+        assertEquals(Arrays.asList(1, 2, 3, 4, 5), o.toSortedList().toBlocking().first());
+    }
 }