Scala プロジェクトで RxJava を使用してObservableおり、別のスレッドで実行する必要があります。observeOnこれを実現するには、メソッドを呼び出して、のインスタンスをrx.lang.scala.Scheduler引数として渡す必要があることを知っています。
しかし、どうすればそのインスタンスを作成できますか? rx.lang.scala.Schedulerトレイトをインスタンス化する明らかな方法は見つかりませんでした。たとえば、次のコードがあります。
Observable.from(List(1,2,3)).observeOn(scheduler)
scheduler誰かがトリックを行う作業変数の例を提供できますか?