是否可以将任意多个定时 Flux 合并为一个？

Question

我知道 combineLatest() 将最后一个值组合到两到六个 Flux 实例 (Combining Publishers in Project ) 中。但是，假设我有一个List<Flux<Integer>> listOfFlux。是否有可能将所有这些组合成一个，例如listOfFlux.combineAllLatest( (a,b) -> a + b) )?

Answer 1

是的，有一个专门的运算符变体：

Flux.combineLatest(Iterable<? extends Publisher<? extends T>> sources,
                                          Function<Object[],V> combinator)

你可以像这样使用它：

List<Flux<Integer>> listOfFlux = //...
Flux<Integer> result = Flux.combineLatest(listOfFlux, arr -> {
    //...
});