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 0f6dd5a commit b027db6Copy full SHA for b027db6
rxjava-core/src/test/java/rx/internal/operators/OperatorParallelTest.java
@@ -81,7 +81,7 @@ public void call(Integer[] v) {
81
assertEquals("finalCount", NUM, count.get());
82
}
83
84
- @Test(timeout = 1000)
+ @Test(timeout = 10000)
85
public void testParallelWithNestedAsyncWork() {
86
int NUM = 20;
87
final AtomicInteger count = new AtomicInteger();
@@ -192,7 +192,7 @@ public String call(Integer t) {
192
assertEquals(2000, ts.getOnNextEvents().size());
193
194
195
196
public void testBackpressureViaSynchronousTake() {
197
final AtomicInteger emitted = new AtomicInteger();
198
TestSubscriber<String> ts = new TestSubscriber<String>();
0 commit comments