android - 如何使 AndroidSchedulers.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)转换为“Scala 调度程序”(rx.lang.scala.Scheduler)的方法- javaSchedulerToScalaScheduler:

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