170 похожих чатов

Господа, вопрос по Reactor. Mono, как его можно "элегантно" использовать, вместо

явного 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));

8 ответов

10 просмотров

так идея в чем? результат послать в sink?

Serj-in Автор вопроса

да, через Mono и чтобы только на старте, новые подписчики не должны получать его дважды

Как инициализируется cf? Что там источник данных?

Serj-in Автор вопроса

то CompletableFuture к базе

Задачу я так и не понял как то

Serj-in Автор вопроса

в примере колбэк пишет в поток, без Mono , интересно как это правильно делать с MOno

Получить моно и подписаться на него

Лол, а что ожидалось?

Похожие вопросы

Обсуждают сегодня

получается, что он находит одинаковое колво тегов, с разными именами, или я что тто не понял в таксоупе ?
Fedor
46
вот такое это из хаскеловской или никсовой ситуации ? пока мне сложно отличить, может кто понимает last 10 log lines: > Running phase: updateAutotoolsGnuConfig...
Fedor
18
не понимаю как в какую сторону искать проблему вот так выглядит Tag в выводе Filtered tag: <a>, href: /url?esrc=s&q=&rct=j&sa=U&url=https://ru.wikipedia.org/wiki/Haskell&ved=2...
Fedor
8
Снова я с выводом номера вхождения подстроки в строку. Исправил код, номер элемента, с которого начинается подстрока в строке, выводит, но неправильно. Подскажите, пожалуйста,...
Ыиу
2
@dt0W3s1yQE75Mew ну чё как чувствуешь себя здесь бот? запомни тупое ты чучело - в ассемблере нету тянок
.
18
а вот так если по инструкции выше Y % Total % Received % Xferd Average Speed Time Time Time Current Dload Upload Total ...
Fedor
7
ого, прикольно, а что пишешь?
CodWiz | Серёжа by CodWiz
32
#include <stdio.h> base( int size_2, int size_1, int ar_1[], int ar_2[][size_2] ){ int cm,im; int ar_3[size_2]; for(int num = 0; num <size_2; num++ ) { ...
Behemoth cat
11
Вопрос, не ставиться haskus-utils-variant (>=3.3 && <3.4) - говорит битый пакет под никсом, есть у кого мысли как чинить ?
Fedor
16
а вот вопрос куда копать не понимаю, вроде работает функция, но возращает странное take 1 ategs [TagBranch "a" [("href","/?sa=X&ved=0ahUKEwiQ7Pbhzs6FAxURBNsEHVRuDAgQOwgC")] [...
Fedor
6
Карта сайта