Convert InputStream to Flow

Question

I would like to read a file contents and emit a flow for every line of its contents. So, I have to implement a function with the following signature:

fun InputStream.linesToFlow(): Flow

Is there any way to implement this function?

user_692422 · Answer

I found the following solution as well:

fun InputStream.linesToFlow() = bufferedReader().lineSequence().asFlow().flowOn(Dispatchers.IO)

user_2741273 · Answer

You can do this

fun InputStream.linesToFlow(): Flow = channelFlow {
    reader().forEachLine { line -> 
        offer(line)
    }
}