Весенний webflux: как опубликовать событие из синхронизирующего вызова для асинхронной обработки? - PullRequest
Новая
       47

Весенний webflux: как опубликовать событие из синхронизирующего вызова для асинхронной обработки?

0 голосов
/ 25 октября 2019

У меня есть метод, который вызывается синхронно. из этого метода я хочу опубликовать другое событие, которое будет обрабатываться асинхронно. Например:

метод синхронизации M вызывается с параметром, этот параметр необходимо отправить на другой сервер X. M должен вернуть ASAP, но X может быть недоступен. если X не работает, асинхронная обработка должна повториться несколько раз спустя несколько секунд

, поэтому у меня есть код, который обрабатывает единственный параметр / событие: 

 return webClient
                .post()
                .uri(...)
                .syncBody(...)
                .retrieve().bodyToMono(...)
                .retryWhen {...}
                .subscribeOn(Schedulers.boundedElastic())

, но как я могу опубликоватьновое событие / параметр из вызова синхронизации?

...