android - RxJava 的 doOnSubscribe 在发出之后而不是之前调用
问题描述
我有一个看起来像这样的 RxJava 链:
Completable.complete()
.andThen(fetchData())
.andThen(fetchAnotherData())
.andThen(...)
.doOnSubscribe {
/* some action */
}
问题是 doOnSubscribe 回调中的代码在 last andThen() 之后调用。但我希望在获取任何数据之前调用它。我如何实现它?
解决方案
尝试defer
订阅fetchData()
Completable
Completable.complete()
.andThen(Completable.defer { fetchData() })
.andThen(Completable.defer { fetchAnotherData() })
.doOnSubscribe { /* some action */ }
推荐阅读
- html - 向右移动按钮
- java - JPA:如何仅从另一个实体映射一个属性
- javascript - 隐藏基于复选框的显示 Div
- java - 如何在 Heroku 中从 python 执行 java 类
- arrays - CompactMap 过滤具有 nil 属性的对象
- react-native - 标题不适用于 react-navigation createStackNavigator
- c# - 无法连接到控制器中的方法
- excel - 如何将总计行添加到 Excel 电源查询?
- python - 如何将多个数据框行合并到一个列表中?
- apache-kafka - pulsar 和 kafka 在消费方面有什么区别?