android - 订阅 Android UI 线程

Question

我是 RxJava 的新手，我想我可能忽略了一些非常基本的东西。所以我创建了一个 Observable 来执行这样一个长时间运行的 I/O 任务。现在我想确保订阅者在 Android UI 线程上收到它的结果:

Observable.create(new ObservableOnSubscribe<Device>() {
    @Override
    public void subscribe(@io.reactivex.annotations.NonNull final ObservableEmitter<Device> e) throws Exception {
        //Long running task
    }
}).subscribeOn(Schedulers.io())

如您所见，我已经在 Schedulers.io() 上执行了长时间运行的任务。如何切换回 Android UI 线程？

Answer 1

你必须执行observeOn(AndroidSchedulers.mainThread())。