fun InputStream.openReadChannel(): ReceiveChannel<String> = produce {
  bufferedReader()
      .useLines { lines ->
        lines.forEach { send(it) }
      }
}

fun main(args: Array<String>) {
  val inputChannel = System.`in`.openReadChannel()
  
  val printJob = launch {
    println("Start to listen on inputs")
    inputChannel.consumeEach { println("User entered: $it") }
    println("Stop to listen on inputs")
  }

  runBlocking {
    delay(10, TimeUnit.SECONDS)

    inputChannel.cancel()

    printJob.join()
  }
}