Skip to content

Commit 4df6f23

Browse files
committed
Merge pull request #2817 from akarnokd/OnBackpressureDropWithActionFix
Fix for non-deterministic: testOnBackpressureDropWithAction
2 parents 1f8b848 + bf941d5 commit 4df6f23

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/rx/BackpressureTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -446,7 +446,7 @@ public void testOnBackpressureDropWithAction() {
446446
final AtomicInteger emitCount = new AtomicInteger();
447447
final AtomicInteger dropCount = new AtomicInteger();
448448
final AtomicInteger passCount = new AtomicInteger();
449-
final int NUM = (int) (RxRingBuffer.SIZE * 1.5); // > 1 so that take doesn't prevent buffer overflow
449+
final int NUM = RxRingBuffer.SIZE * 3; // > 1 so that take doesn't prevent buffer overflow
450450
TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
451451
firehose(emitCount).onBackpressureDrop(new Action1<Integer>() {
452452
@Override

0 commit comments

Comments
 (0)