Merge pull request ReactiveX#1474 from mattrjacobs/ignore-backpressur…

…e-operator-tosortedlist Ignore backpressure for OperatorToObservableSortedList
ilayaperumalg · Jul 22, 2014 · 077d70a · 077d70a
2 parents 52c6ca0 + 160a758
commit 077d70a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/rxjava-core/src/main/java/rx/internal/operators/OperatorToObservableSortedList.java b/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 {

diff --git a/rxjava-core/src/test/java/rx/internal/operators/OperatorToObservableSortedListTest.java b/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());
+    }
 }