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

Question

我的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))
                                                                 ^

请帮忙解决这个问题.

Answer 1

本JavaConversions类包含您需要从"Java的时间表"转换方法(rx.Scheduler)的"斯卡拉调度程序"(在rx.lang.scala.Scheduler) - javaSchedulerToScalaScheduler:

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