Kotlin 流和文件 IO

问题描述

我有一个 Flow<FileChunk> 需要附加到文件中。我天真的方法是：

     File(fileame).bufferedWriter().use { writer ->
        withContext(IO) {
            requests.collect {
                writer.write(it.fileChunk.content.toStringUtf8())
            }
        }
    }

不幸的是，IntelliJ 将“写入”标记为“阻塞”。实现我想要的东西的正确方法是什么？谢谢！

解决方法

您实际上需要一个 CoroutineScope 来启动 suspend 函数。在这种情况下，我会选择以下两个选项：

1. 创建或使用可用的协程范围。例如：

 File(fileame).bufferedWriter().use { writer ->
        CoroutineScope(Dispatchers.IO).launch{
            requests.collect {
                writer.write(it.fileChunk.content.toStringUtf8())
            }
        }
    }

2. 或者，如果您在函数内部，则可以将其设为 suspend fun，并在函数调用站点上处理协程范围