如何按顺序执行单元表

我有一个要处理的单声道列表，但它们必须按顺序执行，而且只有在前一个单声道完成后才能执行下一个单声道。

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();

但这会在前一个单声道完成之前执行下一个单声道。

---

解决方案

Flux#concatMap是此情况的最佳选择。

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

这里有一个完整的示例：

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