ConnectedStreamsApp.scala

object ConnectedStreamsApp extends App {
  def writer(outputStream: OutputStream): Unit = {
    val writer = new PrintStream(outputStream)
    (1 to 1000).foreach { i =>
      writer.println(s"line $i")
      Thread.sleep(50)
    }
    writer.close()
  }

  def reader(inputStream: InputStream): Unit = {
    val reader = new BufferedReader(new InputStreamReader(inputStream))
    while (true) {
      var line = reader.readLine()
      if (line == null) {
        reader.close()
        return
      }
      println(s"read: $line")
    }
  }

  val in  = new PipedInputStream(4024)
  val out = new PipedOutputStream(in)

  val writerThread = new Thread(() => writer(out))
  writerThread.start()
  reader(in)
  writerThread.join()
}