如何在RxScala / Java中使用多个线程执行map,filter,flatMap？

发布时间：2020-12-15 02:11:25 所属栏目：Java 来源：网络整理

导读：如何使用多个线程在Observable上运行filter,map和flatMap： 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 = { wit

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

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(_))

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

解决方法

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

它位于包rxjava-async上

Documentation

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!