Mono 到 Flux 的 Spring 响应式列表答案

【问题标题】：Spring Reactive List of Mono to FluxMono 到 Flux 的 Spring 响应式列表
【发布时间】：2020-03-17 13:42:14
【问题描述】：

我有一个

list.stream()
.map(element -> func());

其中 func() 使用 Mono 返回。将此Mono<CustomObject> 对象列表转换为Flux<CustomObject> 并从流中返回的最简单方法是什么？

【问题讨论】：

【解决方案1】：

List<Mono<CustomObject >> monoList = new ArrayList<>();
monoList(object);

Flux<CustomObject> flux = Flux.concat(monoList);

【讨论】：

嗨 vijay，你能在你的代码示例周围添加一些上下文吗？
Flux != Flux>
请评论您的代码，以便您尝试帮助的人了解代码的作用以及它如何解决他们的问题。
请评论您的代码，以便您尝试帮助的人了解代码的作用以及它如何解决他们的问题。
1. Mono 基本上是一个源在给定时间点发出（顺序）的数据项。 monoList 是这样的 Monos 的集合，其中列表包含由下游系统发出并添加到集合中的多个数据项（在本例中为 List）。类似地，可能有一个或多个这样的源顺序发出项目，这意味着存在多个 Mono 列表。 2. 结合每一个来源，形成所有数据项的连续流。考虑：顺序或急切地订阅多个数据源？一种。 concat：顺序 b。合并：渴望