我有一个RxJava的链,看起来像这样:
Completable.complete()
.andThen(fetchData())
.andThen(fetchAnotherData())
.andThen(...)
.doOnSubscribe {
/* some action */
}
问题是doOnSubscribe回调中的代码在last andThen()之后调用。但是我希望在获取任何数据之前先调用它。如何实现?
尝试defer
订阅fetchData()
已完成
Completable.complete()
.andThen(Completable.defer { fetchData() })
.andThen(Completable.defer { fetchAnotherData() })
.doOnSubscribe { /* some action */ }