链中的 RxJava 多个 subscribeOn()

Question

我想知道当我们在 RxJava 链中有多个 subscribeOn() 方法时会发生什么。例如，如果我有一个类似这样的链条，

    Single.fromCallable { repository.apiCall1() }
        .subscribeOn(Schedulers.io())
        .flatMap { result -> Single.fromCallable { repository.apiCall2() } }
        .subscribeOn(Schedulers.io())
        .map { // do something }
        .observeOn(Schedulers.ui())

这是否意味着 API 调用运行的线程不同？删除上面这条链中的第一个 subscribeOn(Schedulers.io()) 调用会有什么影响/效果？

感谢您对此的任何见解

Answer 1

它看起来不会有任何影响。无论您将subscribeOn 放在链中的哪个位置都会产生相同的效果。

根据文档，observeOn 具有不同的行为，因此您可以更改在链中的任何点观察结果的线程。

来自 Rx 文档：

SubscribeOn 操作符指定 Observable 将使用哪个线程 开始运营，无论在运营商链中的哪个点 该运算符被调用。另一方面，ObserveOn 会影响 Observable 将在该运算符出现的下方使用的线程。 出于这个原因，你可以在不同的地方多次调用 ObserveOn Observable 运算符链中的点，以便更改 这些运算符中的某些线程在运行。

http://reactivex.io/documentation/operators/subscribeon.html