How to use multiple threads to execute map, filter and flatmap in rxscala / Java?

How to use multiple threads to run filter, map and flatmap on 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(_))

The goal is to use multiple threads to run filtering and transformation operations at the same time

Solution

Yo can use async. On each operation toAsync().

It is located on the package rxjava async

Documentation