Skip to content

Commit 47a1af4

Browse files
committed
Add more time to DispatchWorkProcessorTest
1 parent fc693b2 commit 47a1af4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/hu/akarnokd/rxjava2/processors/DispatchWorkProcessorTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,7 @@ public HashSet<Integer> apply(List<Integer> a, List<Integer> b)
379379

380380
Flowable.range(0, n).subscribe(dws);
381381

382-
to.awaitDone(5, TimeUnit.SECONDS)
382+
to.awaitDone(10, TimeUnit.SECONDS)
383383
.assertValueCount(1)
384384
.assertNoErrors()
385385
.assertComplete();
@@ -417,7 +417,7 @@ public HashSet<Integer> apply(List<Integer> a, List<Integer> b)
417417

418418
Flowable.range(0, n).subscribeOn(Schedulers.single()).subscribe(dws);
419419

420-
to.awaitDone(5, TimeUnit.SECONDS)
420+
to.awaitDone(10, TimeUnit.SECONDS)
421421
.assertValueCount(1)
422422
.assertNoErrors()
423423
.assertComplete();

0 commit comments

Comments
 (0)