We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a917b91 commit bf941d5Copy full SHA for bf941d5
src/test/java/rx/BackpressureTests.java
@@ -446,7 +446,7 @@ public void testOnBackpressureDropWithAction() {
446
final AtomicInteger emitCount = new AtomicInteger();
447
final AtomicInteger dropCount = new AtomicInteger();
448
final AtomicInteger passCount = new AtomicInteger();
449
- final int NUM = (int) (RxRingBuffer.SIZE * 1.5); // > 1 so that take doesn't prevent buffer overflow
+ final int NUM = RxRingBuffer.SIZE * 3; // > 1 so that take doesn't prevent buffer overflow
450
TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
451
firehose(emitCount).onBackpressureDrop(new Action1<Integer>() {
452
@Override
0 commit comments