如何让AndroidScheduler.mainThread与Scala Observable一起使用

发布时间：2020-12-16 18:16:41 所属栏目：安全来源：网络整理

导读：我的oncreate中有一个Observable,我希望在主线程上得到结果.但由于 AndroidScheduler.mainThread只与Java Observable一起使用,我无法编译它.这是代码 val L=List(1,2,3)val a=Observable.from(L).observeOn(AndroidSchedulers.mainThread()).subscribe(i=pri

我的oncreate中有一个Observable,我希望在主线程上得到结果.但由于 AndroidScheduler.mainThread只与Java Observable一起使用,我无法编译它.这是代码

val L=List(1,2,3)
val a=Observable.from(L).observeOn(AndroidSchedulers.mainThread()).subscribe(i=>println(i))

这里’a’是一个rx.scala.lang Observable.这是我得到的编译时错误

Error:(38,70) type mismatch;
 found   : rx.Scheduler
 required: rx.lang.scala.Scheduler
 val a=Observable.from(L).observeOn(AndroidSchedulers.mainThread()).subscribe(i=>println(i))
                                                                 ^

请帮忙解决这个问题.

解决方法

JavaConversions类包含从“Java Scheduler”(rx.Scheduler)转换为“Scala Scheduler”(rx.lang.scala.Scheduler)所需的方法 – javaSchedulerToScalaScheduler：

val a=Observable.from(L)
        .observeOn(JavaConversions.javaSchedulerToScalaScheduler(AndroidSchedulers.mainThread()))
        .subscribe(i=>println(i))

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!