我正在尝试用反应性来改变助焊剂。使用包含列表的POJO键入Flux。我想将我的Flux重新映射到一个包含所有POJO的所有子代的新Flux。
就像使用map
的Flux
方法一样,但不是每个输入生成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/