явного CompletableFuture ?
цель - задать начальное значение кэша из базы
Sinks.Many<String> sinks = Sinks.many().replay().latest();
Mono.fromFuture(cf.whenComplete((n, ex) -> {
if (ex == null) {
sinks.tryEmitNext(n);
} else {
throw new RuntimeException(ex);
}
}));
Flux<String> stream = sinks.asFlux();
stream.subscribe(n -> LOG.info("[1] - {}", n));
так идея в чем? результат послать в sink?
да, через Mono и чтобы только на старте, новые подписчики не должны получать его дважды
Как инициализируется cf? Что там источник данных?
то CompletableFuture к базе
Задачу я так и не понял как то
в примере колбэк пишет в поток, без Mono , интересно как это правильно делать с MOno
Получить моно и подписаться на него
Лол, а что ожидалось?
Обсуждают сегодня