RxJava的doOnSubscribe在发出之后不早于

问题描述 投票:0回答:1

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

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

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

android kotlin rx-java2
1个回答
1
投票

尝试defer订阅fetchData()已完成

   Completable.complete()
            .andThen(Completable.defer { fetchData() })
            .andThen(Completable.defer { fetchAnotherData() })
            .doOnSubscribe { /* some action */ }
© www.soinside.com 2019 - 2024. All rights reserved.