可以将 Flux 转换为 Mono

Question

我正在使用 r2dc 作为 Spring Boot Java 应用程序。

我在想是否可以将 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

您需要使用collectList()方法将Flux其转换Flux<Foo>为Mono<List<Foo>>. 这是你能做的最好的事情了。