kotlin - 将 InputStream 转换为流

Question

我想读取文件内容并为其内容的每一行发出一个流。所以，我必须实现一个具有以下签名的函数：

fun InputStream.linesToFlow(): Flow<String>

有没有办法实现这个功能？

Answer 1

我也找到了以下解决方案：

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

Answer 2

你可以这样做

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