Asnyc exmaple

async.scala

import rx.lang.scala.Observable._
import rx.lang.scala.JavaConversions._
import rx.lang.scala.ImplicitFunctionConversions._
import rx.util.async.Async
import java.util.concurrent.Executors
import rx.schedulers.Schedulers

object Test extends App {

  val executor = Executors.newFixedThreadPool(10)
  val scheduler = Schedulers.executor(executor)

  val o = Async.start({
    // some blocking actions
    Thread.sleep(2000)
    1
  }, scheduler)

  println(o.toBlockingObservable().single())
  
  executor.shutdown()
}