Проблема с вызовом функции Java ReactorJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Проблема с вызовом функции Java Reactor

Сообщение Anonymous »

Я пытаюсь работать с различными операциями 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
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»