Я пытаюсь работать с различными операциями Mono в приведенном ниже блоке кода
@Test
public void just() throws InterruptedException {
Mono test = Mono.zip(testMono1(), testMono3())
.flatMap(tuple -> {
System.out.println("test flatmap" + tuple.getT1());
return Mono.just(tuple.getT2());
});
test.block();
// test.subscribe(val -> log.info("Subscriber received: {}", val));
}
public Mono testMono1() {
return Mono.fromRunnable(() -> {
System.out.println("test1");
})
.then();
}
public Mono testMono3() {
return Mono.fromRunnable(() -> {
System.out.println("test3");
})
.thenReturn(true);
}
test3 никогда не печатается, и ни одна тестовая плоская карта не печатается.
Я пытался подписаться на тестовое моно, а также пробовал блокировать вызовы, как показано в коде. , но я до сих пор не могу разобраться в проблеме.
Мой вывод
test1
Process finished with exit code 0
Если я раскомментирую вызов подписки, результат будет следующим:
test1
test1
Process finished with exit code 0
Подробнее здесь: https://stackoverflow.com/questions/783 ... call-issue
