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

Раз уж даже такой чат есть, не могу еще и

тут не спросить :) может кто работал с webflux и знает, каким образом можно в хендлере вебсокет соединения без блокировки дождаться выполнения условия средствами самого webflux? Нужно буквально подвесить метод (while(true) / CountDownLatch и т.д.) но не ломать реактивность

суть в том, что нужно отправить данные в Kinesis дождаться обработки и получения ответа от SQS

7 ответов

8 просмотров

Так верни из хэндлера Mono/Flux, как появятся данные они по подписке полетят дальше

А, надо на примитиве синхронизации подождать? А кто решает что пора просыпаться?

Artem-Z Автор вопроса
Alexandr ∨∧‾ Emelyanov
Так верни из хэндлера Mono/Flux, как появятся данн...

проблема в том, что если при вызове метода возвращающего Flux условие не срабатывает, то Flux все равно возвращается, просто пустой и пайплайн в хендлере отрабатывает возвращая ответ кривой. Но я тут вроде нашел, что через интервал можно сделать и оно вроде почти заработало... у меня больше проблема в том что я первый раз этот вебфлакс вижу и доки у них какие то не очевидные)

Artem-Z Автор вопроса
Alexandr ∨∧‾ Emelyanov
А, надо на примитиве синхронизации подождать? А кт...

нужно дождаться события из SQS и обновления значения мапы. Т.е. из sqs просто валится куча событий и клиенты ждут когда ответ для них будет тут довольно мутная логика размазанная по лямбдам и объекты прокидываются через несколько очередей, но по сути нужно вот сделать что -то вроде while(true): if (map.get(key) != null): return Message

Artem Z
проблема в том, что если при вызове метода возвращ...

Если флюкс пустой, то ничего не отправится, что то не то

Artem-Z Автор вопроса
Alexandr ∨∧‾ Emelyanov
Если флюкс пустой, то ничего не отправится, что то...

ну я делал что -то вроде ``` webSocketSession.receive() .map(message -> service.getData(message)) .map(session::textMessage); .. getData() { return Flux.create(sink -> { ... sink.next(answer) }) } и вот кажется я просто что -то пропустил, т.к. у меня клиент тупо строку начал получать "Flux.create"

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

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

Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
База данных не поможет. Шифрование не поможет. Какие там ещё варианты? Накидывайте.
КТ315
20
А как лучше конвертировать физический адрес в виртуальный при маппинге? В случае ядра у меня, например, direct mapping, первые 768МБ я как есть мапплю в higher half, а остальн...
Evg Resh
26
А табстоп это сообщение от окна или от элемента управления?
The Bird of Hermes
18
Открыл свой двухкилобайтный экзешник в x32dbg, а тут какая-то хрень. Смущает кнопка "выполнить до пользовательского кода", а что ещё может быть в файле помимо него ?
НѣкъиⰘижєжєиꙁъвьсєсвѣтьноѣсѣтиѥсть•
11
Вопрос тем кто смотрит видео и слушает подкасты - как вы потом ищете нужную вам информацию? Вот статью я прочитал, потом могу искать нужную мне часть банальным поиском. Пропус...
Aleksandr Druzhinin
4
Мне были интересны дишные хаки и я нашёл любопытный способ на форуме через __traits, что-то вроде int delegate(int) fac = (int n) => n == 0 ? 1 : n * __traits(parent, {})(n - ...
Constantin F.
1
Всем привет, подскажите/посоветуйте пожалуйста. Фаердак компоненты, имею одно место где бизнес хочет видеть при открытии формы список всех клиентов, это порядка 30к. Мои дово...
Sasha Sch
14
Ребят, если кто в курсе - скажите, а в загранке такое же засилье маркетплейсов? или там простые сермяжные интернет-магазины живут попроще?
Андрей [aharito] Харитонов
14
@FAssembler ты много с формами работал, как цикл обработки сообщений от окошек надо делать, чтобы IsDialogMessage не ломал ввод в эдиты и навигация по табам работала?
The Bird of Hermes
8
Карта сайта