Scala implementation of redis subscribe

Main.scala

import com.redis.RedisClient
 
import rx.lang.scala._
import rx.lang.scala.schedulers._
 
object Main {
  def main(args: Array[String]): Unit = {
    val o = Observable.create(func)
    o.subscribe(println(_))
 
    o.toBlocking.last // block process to see it works.
  }
 
  def func(ob: Observer[String]): Subscription = {
    val c = new RedisClient()
    val worker: Worker = ComputationScheduler().createWorker
    worker.schedule { // new thread
      c.subscribe("test_channel")(x => {
        ob.onNext(x.toString)
      })
    }
  }
}