Spring Webflux Flux<List<MyPojo>> 到 Flux<MyPojo>

Question

关于如何在 Spring Webflux 中将 Flux 转换为 Flux 的小问题。

我尝试了一些 reduce 和 flat map 的组合，但没有得到 Flux。

如果可能，请问从 Flux 获取 Flux 的正确方法是什么？

非常感谢。

Answer 1

你可以使用flatMapIterable:

Flux<List<MyPojo>> myFlux = ...
myFlux.flatMapIterable(p -> p).map(myPojo -> ...)

请参阅flatMapIterable here 的文档。