Можете ли вы Flux.zip моно и поток и повторить моно значение для каждого значения потока? - PullRequest
0 голосов
/ 15 января 2020

Можно ли сделать что-то вроде кода ниже? У меня есть один сервис, который выполняет вызов API, и другой, который возвращает поток значений. Мне нужно изменить каждое значение на значение, возвращаемое вызовом API.

return Flux.zip(
                     someMono.get(),
                     someFlux.Get(),
                     (d, t) -> {
                         //HERE D IS ALWAYS THE SAME AND T IS EVERY NEW FLUX VALUE
                     });

Я пробовал с .repeat () для Mono, и он работает, но он вызывает метод каждый раз, когда появляется новый Значение потока и это вызов API, так что это не хорошо.

Возможно ли это?

...