A working with Observable.from and Future example

futureObserver.scala

// from https://groups.google.com/d/msg/rxjava/GyVmw-ttbDY/qGHSO5EiEugJ
import rx.lang.scala._
import scala.concurrent._
import ExecutionContext.Implicits.global
import java.util.concurrent.TimeUnit

println(s"Current thread: ${Thread.currentThread.getName()}")  // run-main-1

def timeConsumingComputation() = {
  TimeUnit.SECONDS.sleep(2)
  "time to get up"
}

val f: Future[String] = future {
  println(s"Future thread: ${Thread.currentThread.getName()}")  // ForkJoinPool-1-worker-5
  timeConsumingComputation()
}

val o = Observable.from(f)
o.subscribe { e => 
  println(s"Received $e")
  println(s"Subscribe thread: ${Thread.currentThread.getName()}")  // ForkJoinPool-1-worker-5
}