java - 异步Java : How to organize nested subscribes that must be done sequentially?

Question

我有一个类似于这样的工作流程:

flux1.subscribe(result1 -> {
    flux2ThatDependsOnResult1.subscribe(result2 -> {
        flux3TheDependsOnResult2.subscribe(result3 -> {
        ...
        })
    })
})

(使用 Spring Webflux)

所有的嵌套使得这段代码难以使用。有更好的方法来写这些吗？

Answer 1

看看 concatMap 或 flatMap 运算符，而不是订阅每个“步骤”