RxJava在多个线程上链接可观察对象

Question

我正在开发利用RxJava、realm和改进的应用程序。

我需要创建非常具体的数据处理链。我需要在io调度程序上执行改装调用，然后在我的自定义单线程领域调度程序上处理提供的数据，然后将结果推送到主线程调度程序上的ui。我试图通过使用多个组合来实现这一点，包括观察（observeOn）和订阅（subscribeOn），但我无法让中间部分在调度程序（scheduler）上执行。

我的目标是这样的调度程序：io ---------------

我如何创建这样的可观察链，其中每个可观察的工作都是在特定的线程上完成的？

非常感谢。




Answer 1

匿名用户

查看Observable.observeOn（...）方法。此方法将确保在提供的计划程序上发生之后发生的所有操作。

为了支持您的自定义“领域”调度器，您需要为RxJava提供某种方式来安排工作。如果您使用的是标准的执行器（如Executors.newSingleThreadExecutor（）来支持Realm的单线程策略），那么您可以使用调度程序。从（Executor）创建一个计划程序，该计划程序将在特定的执行器上执行。

ExecutorService realm = Executors.newSingleThreadExecutor();
Scheduler realmScheduler = Schedulers.from(realm);
Retrofit source;

source.call()
      .subscribeOn(Schedulers.io())
      .observeOn(realmScheduler)
      .map(DataBaseUpdate)
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(UIUpdate)