iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed failing reactive test

This commit is contained in:
Andrew Morgan 2017-02-22 20:36:42 +00:00
parent 73026b6565
commit 6bbb4cfef4
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
reactor-core/src/test/java/com/baeldung/reactor/ReactorTest.java
View File

@ -92,7 +92,7 @@ public class ReactorTest {
} }
@Test @Test
public void givenFlux_whenInParalle_shouldSubscribeInDifferentThreads() { public void givenFlux_whenInParalle_shouldSubscribeInDifferentThreads() throws InterruptedException {
List<Integer> elements = new ArrayList<>(); List<Integer> elements = new ArrayList<>();
Flux.just(1, 2, 3, 4) Flux.just(1, 2, 3, 4)
@ -101,6 +101,8 @@ public class ReactorTest {
.subscribeOn(Schedulers.parallel()) .subscribeOn(Schedulers.parallel())
.subscribe(elements::add); .subscribe(elements::add);
Thread.sleep(1000);
assertThat(elements).containsExactly(2, 4, 6, 8); assertThat(elements).containsExactly(2, 4, 6, 8);
} }