Blocking input flow

BlockingInputFlow.kt

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

fun main() = runBlocking<Unit> {
    // working in the main thread
    val stdinFlow = System.`in`.bufferedReader().lineSequence().asFlow()
    // lets launch a coroutine that collects this flow and prints lines:
    stdinFlow.onEach { println(it) }.launchIn(this)
    // is the main thread active or blocked?
    println("I'm not blocked yet")
    // now yield main thread the the launched coroutines
    yield()
    // is it blocked now?
    println("I'm still not blocked yet, hooray!")
}