我在我的Scala项目中使用RxJava,并且我需要在一个单独的线程中执行我的Observable
。我知道为了实现这一点,我需要对它调用observeOn
方法,并将rx.lang.scala.Scheduler
的一个实例作为参数进行传递。
但是,如何创建该实例呢?我没有找到任何明显的方法来实例化rx.lang.scala.Scheduler
特征。例如,我有这样的代码:
Observable.from(List(1,2,3)).observeOn(scheduler)
有人能提供一个可以工作的scheduler
变量的例子吗?
https://stackoverflow.com/questions/24046554
复制相似问题