如何解决Kotlin 流和文件 IO
我有一个 Flow<FileChunk>
需要附加到文件中。我天真的方法是:
File(fileame).bufferedWriter().use { writer ->
withContext(IO) {
requests.collect {
writer.write(it.fileChunk.content.toStringUtf8())
}
}
}
不幸的是,IntelliJ 将“写入”标记为“阻塞”。实现我想要的东西的正确方法是什么?谢谢!
解决方法
您实际上需要一个 CoroutineScope
来启动 suspend
函数。在这种情况下,我会选择以下两个选项:
- 创建或使用可用的协程范围。例如:
File(fileame).bufferedWriter().use { writer ->
CoroutineScope(Dispatchers.IO).launch{
requests.collect {
writer.write(it.fileChunk.content.toStringUtf8())
}
}
}
- 或者,如果您在函数内部,则可以将其设为
suspend fun
,并在函数调用站点上处理协程范围
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。