我正在尝试用反应性来改变助焊剂。使用包含列表的POJO键入Flux。我想将我的Flux重新映射到一个包含所有POJO的所有子代的新Flux。

就像使用mapFlux方法一样,但不是每个输入生成1个项目,而是应生成0到n个项目。实现此目标的最佳方法是什么?

最佳答案

.flatMap(Flux::fromIterable)吗?

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


如果您要对POJO属性进行一些投影,则可以简单地继续操作,并为.map()中嵌套的Flux调用flatMap

关于java - 助焊剂生产商一对多,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/45613784/

10-11 19:31