Is there a way to launch a coroutine that 'listens...

# coroutines

[asad.awadia]

Is there a way to launch a coroutine that 'listens' to stdin input while the rest of the program runs? something like launch { while(true) { //listen to keyboard input and do stuff } }

[Jonathan]

what about:```
/**
* Create a listener for stdin [System.in] and return a channel through which all user inputs lines are sent.
*
* (One element in the channel = one line entered by the user)
*
* Closing the channel would end the listener
*/
fun createStdindListener(): ReceiveChannel<String> = produce {
System.in.bufferedReader()
.useLines { lines ->
lines.forEach { send(it) }
}
}
```

[Jonathan]

Here is a more generic implementation and how to use it:

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()
  }
}