subscribeOn并且
observeOn是那里最混乱的运营商。前者确保订阅副作用在指定的调度程序(线程)上发生,但这并不意味着值也将在该线程上弹出。
例如,如果您的观察者在订阅时打开了一个网络连接,则您不希望该链接在主线程上运行,因此,您需要subscriptionOn来指定该订阅的位置,从而创建网络连接。
当数据最终到达时,发出线程可以是任何东西,调度程序之一或后台普通旧线程。由于我们不知道或不喜欢该线程,因此我们希望将对数据的观察移到另一个线程。这是observeOn的作用:确保操作符之后的操作符将在指定的调度程序上执行其onNext逻辑。Android开发人员已经使用它来将对值的观察移回主线程。
但是很少解释的是,当您希望在最终结果再次落入主线程之前又需要在主线程上进行一些额外的计算时会发生什么:使用多个
observeOn运算符:
source.observeOn(Schedulers.computation()).map(v -> heavyCalculation(v)).observeOn(Schedulers.io()).doonNext(v -> { saveToDB(v); }).observeOn(AndroidSchedulers.mainThread())...


