Failing unit test for reduce, showing it does not implement backpressure correctly

Author: mattrjacobs

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

@@ -16,6 +16,7 @@
 
 package rx.internal.operators;
 
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.times;
@@ -114,4 +115,18 @@ public Integer call(Integer t1) {
         verify(observer, times(1)).onError(any(TestException.class));
     }
 
+    @Test(timeout = 13000)
+    public void testBackpressure() throws InterruptedException {
+        Observable<Integer> source = Observable.from(1, 2, 3, 4, 5, 6);
+        Observable<Integer> reduced = source.reduce(new Func2<Integer, Integer, Integer>() {
+            @Override
+            public Integer call(Integer i1, Integer i2) {
+                return i1 + i2;
+            }
+        });
+
+        Integer r = reduced.toBlocking().first();
+        assertEquals(21, r.intValue());
+    }
+
 }