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

Add blockingHelloWorld()

Browse Source
This commit is contained in:
gindex 2020-04-10 13:36:51 +02:00
parent ba65e09989
commit 5a1f7ffea8
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
reactor-core/src/test/java/com/baeldung/mono/MonoUnitTest.java
View File

@ -12,13 +12,13 @@ import static org.junit.Assert.assertEquals;
public class MonoUnitTest { public class MonoUnitTest {
@Test @Test
public void whenMonoProducesString_thenBlockAndConsume() { public void whenMonoProducesString_thenBlockAndConsume() {
String expected = "hello world!";
String result1 = Mono.just(expected).block(); String result1 = blockingHelloWorld().block();
assertEquals(expected, result1); assertEquals("Hello world!", result1);
String result2 = Mono.just(expected).block(Duration.of(1000, ChronoUnit.MILLIS)); String result2 = blockingHelloWorld()
assertEquals(expected, result2); .block(Duration.of(1000, ChronoUnit.MILLIS));
assertEquals("Hello world!", result2);
Optional<String> result3 = Mono.<String>empty().blockOptional(); Optional<String> result3 = Mono.<String>empty().blockOptional();
assertEquals(Optional.empty(), result3); assertEquals(Optional.empty(), result3);
@ -26,14 +26,18 @@ public class MonoUnitTest {
@Test @Test
public void whenMonoProducesString_thenConsumeNonBlocking() { public void whenMonoProducesString_thenConsumeNonBlocking() {
String expected = "hello world!";
Mono.just(expected) blockingHelloWorld()
.doOnNext(result -> assertEquals(expected, result)) .doOnNext(result -> assertEquals("Hello world!", result))
.subscribe(); .subscribe();
Mono.just(expected) blockingHelloWorld()
.subscribe(result -> assertEquals(expected, result)); .subscribe(result -> assertEquals("Hello world!", result));
} }
private Mono<String> blockingHelloWorld() {
// blocking
return Mono.just("Hello world!");
}
} }