助焊剂生产者一对多

【问题标题】：Flux producer one-to-many助焊剂生产者一对多
【发布时间】：2017-08-10 12:29:14
【问题描述】：

我正在尝试使用 Reactive 转换 Flux。 Flux 使用包含列表的 POJO 键入。我想将我的 Flux 重新映射到包含所有 POJO 的所有子级的新 Flux。

这就像使用 Flux 的 map 方法，但不是每个输入生成 1 个项目，而是应该生成 0 到 n 个项目。实现这一目标的最佳方法是什么？

【问题讨论】：

【解决方案1】：

.flatMap(Flux::fromIterable)?

Flux.just(Arrays.asList("foo", "bar"))
            .flatMap(Flux::fromIterable)
            .subscribe(System.out::println);

如果您的意思是 POJO 属性的一些投影，您可以简单地继续调用 .map() 以在 flatMap 中为嵌套的 Flux 调用。

【讨论】：