助焊剂生产商一对多

Question

我正在尝试用助焊剂改造助焊剂。 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属性的一些投影，你可以简单的继续前进，并呼吁.map()在flatMap该嵌套Flux。