Create RxJava Observable from Socket

SocketReactive.scala

import rx.lang.scala._
import java.net.Socket
import scala.util.Try
import scala.io.Source

object SocketReactive extends App {
  val s= Observable.using[Char,Socket](new Socket("localhost",1234))(
      socket => Observable.from[Char](Source.fromInputStream(socket.getInputStream).toIterable),
      socket=>Try{socket.close})  

     s.foreach{print}
}