BufferedReader as Observable

  override def unsafeSubscribeFn(subscriber: Subscriber[String]): Cancelable = {
    val bufferedObs = Observable.fromLinesReader(bufferedReader)
    val obs1 = Observable.interval(1.second)
      .flatMap(elem => {
        val out = new PrintStream(socket.getOutputStream)
        out.print(s"test$elem\n")
        out.flush()
        bufferedObs
      })

    val obs2 = Observable.interval(1.second)
      .map(elem => {
        val out = new PrintStream(socket.getOutputStream)
        out.print(s"test$elem\n")
        out.flush()
        bufferedReader.readLine() // reads the line as it gets from the server
      })

    obs1.subscribe(subscriber)
  }