助焊剂生产者一对多

Question

我正在尝试使用 Reactive 转换 Flux。 Flux 使用包含列表的 POJO 进行类型化。我想将我的 Flux 重新映射到包含所有 POJO 的所有子项的新 Flux。

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

Answer 1

.flatMap(Flux::fromIterable) ?

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

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

Flux producer one-to-many