scala - 如何在 RxScala/Java 中使用多线程执行 map、filter、flatMap？

Question

如何运行 filter , map和 flatMap在 Observable使用多线程:

  def withDelay[T](delay: Duration)(t: => T) = {
    Thread.sleep(delay.toMillis)
    t
  }

  Observable
    .interval(500 millisecond)
    .filter(x => {
      withDelay(1 second) { x % 2 == 0 }
    })
    .map(x => {
      withDelay(1 second) { x * x }
    }).subscribe(println(_))

目标是使用多个线程同时运行过滤和转换操作。

Answer 1

你可以在每个操作上使用 Async.toAsync() 。

它在包 rxjava-async 上

Documentation