如何按顺序执行单元表 [英] How to execute list of Mono sequentialy

问题描述

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

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

这篇关于如何按顺序执行单元表的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！