将 List<Mono<String>> 转换为 Flux<String>

Question

问题很少，但答案非常具体于某些代码。

一般来说，如何将 Mono Stream 转换为 Flux

List<Mono<String> listOfMono = stream()
.map( s -> { do something and return Mono<String> } )
.collect(Collectors.toList());

如何将listOfMono对象转换为Flux<String>

Answer 1

您可以使用fromIterable，然后使用flatMap来展平Mono

将此 Flux 发出的元素异步转换为 Publisher，然后通过合并将这些内部发布者扁平化为单个 Flux，从而允许它们交错。

Flux<String> result = Flux.fromIterable(listOfMono)
            .flatMap(Function.identity());