java - 将 List 转换为 Flux

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

Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.

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