subscribeOn Android UI线程

概述我是RxJava的新手,我想我可能会忽略一些非常基本的东西.所以我创建了一个Observable来执行像这样的长时间运行的I/O任务.现在我想确保订阅者在AndroidUI线程上收到其结果：Observable.create(newObservableOnSubscribe<Device>(){@Overridepublicvoidsubscribe(@i

我是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线程？

解决方法:

你必须执行observeOn(AndroIDSchedulers.mainThread()).

总结

以上是内存溢出为你收集整理的subscribeOn Android UI线程全部内容，希望文章能够帮你解决subscribeOn Android UI线程所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。