Асинхронная Java: как организовать вложенные подписки, которые должны выполняться последовательно?

Question

У меня есть рабочий процесс, похожий на этот:

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

(с использованием Spring Webflux)

Все вложения затрудняют работу с этим кодом.Есть ли лучший способ написать это?

Answer 1

Взгляните на concatMap или flatMap операторов вместо подписки на каждый "шаг"