Kotlin流和文件IO

Question

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

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

不幸的是，IntelliJ将"；写"；作为"；阻塞"；。实现我想要的东西的正确方式是什么？谢谢

Answer 1

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

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

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

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