I’m seeing a strange issue with coroutines inside of

Flow

. I’m performing a blocking call on a coroutine thread (Using Dispatchers.IO), and because of that, even though the Collecting flow is finished, the cancellation logic (killing a process in this case), doesn’t happen for a good while after:

try {
    while (currentCoroutineContext().isActive && process.isAlive) {
        val line = bufferedProcessSource.readUtf8Line() ?: break
        emit(line)
    }
} catch (e: CancellationException) {
    throw e
} finally {
    if (process.isAlive) {
        println("C$id - Destroying Process")
        process.destroy()
    }
}