flatMapAsync test was non-deterministic

Author: benjchristensen

rxjava-core/src/test/java/rx/BackpressureTests.java

@@ -173,10 +173,12 @@ public Observable<Integer> call(Integer i) {
         }).take(NUM).subscribe(ts);
         ts.awaitTerminalEvent();
         ts.assertNoErrors();
-        System.out.println("testFlatMapAsync => Received: " + ts.getOnNextEvents().size() + "  Emitted: " + c.get());
+        System.out.println("testFlatMapAsync => Received: " + ts.getOnNextEvents().size() + "  Emitted: " + c.get() + " Size: " + RxRingBuffer.SIZE);
         assertEquals(NUM, ts.getOnNextEvents().size());
-        // expect less than 1 buffer since the flatMap is emitting 10 each time, so it is NUM/10 that will be taken.
-        assertTrue(c.get() <= RxRingBuffer.SIZE);
+        // even though we only need 10, it will request at least RxRingBuffer.SIZE, and then as it drains keep requesting more
+        // and then it will be non-deterministic when the take() causes the unsubscribe as it is scheduled on 10 different schedulers (threads)
+        // normally this number is ~250 but can get up to ~1200 when RxRingBuffer.SIZE == 1024
+        assertTrue(c.get() <= RxRingBuffer.SIZE * 2);
     }
 
     @Ignore