RxJava 的 doOnSubscribe 在发出之后而不是之前调用

Question

我有一个看起来像这样的 RxJava 链：

Completable.complete()
    .andThen(fetchData())
    .andThen(fetchAnotherData())
    .andThen(...)
    .doOnSubscribe {
        /* some action */
    }

问题是 doOnSubscribe 回调中的代码在 last andThen() 之后调用。但我希望在获取任何数据之前调用它。如何实现？

Answer 1

尝试defer订阅fetchData()完成

   Completable.complete()
            .andThen(Completable.defer { fetchData() })
            .andThen(Completable.defer { fetchAnotherData() })
            .doOnSubscribe { /* some action */ }