如何执行单序列列表

Question

private Mono<List<Result>> processGoals(List<> goals,Data data) {
    
    List<Mono<Result>> plans = goals
                              .stream()
                              .map(plan -> processGoal(plan, data))
                              .collect(Collectors.toList());

}

return Flux.concat(plans).subscribeOn(Schedulers.single()).collectList();

Answer 1

flux#concatmap是这种情况下的最佳选择。

它将按顺序合并每个映射的发布服务器，并一次激发一个发布服务器，而不必显式定义concurrency参数。

下面是一个完整的示例：

Flux.fromIterable(goals))
        .concatMap(goal -> processGoal(goal, data))
        .collectList();