可以将 Flux 转换为 Mono

Question

我在 spring 引导 java 应用程序中使用 r2dc。

我在考虑是否可以将 Flux 转换为 Mono 以进行某些计算。

伪例子：

static PseudoMagic calculate(List<Foo> foos) {
   return callTheMagicRutine(foos)
}

Mono<PseudoMagic> getMyMagic() {
   Flux<Foo> foos = getMyFoos()
   foos.transformToMagic(f -> calculator(f))
}

Answer 1

您需要在 Flux 中使用 collectList() 方法将 Flux<Foo> 转换为 Mono<List<Foo>>。那是你能做的最好的。