kotlin - 如何从不同的函数发出 Flow 值？ Kotlin 协程

Question

我有一个流程:

val myflow = kotlinx.coroutines.flow.flow<Message>{}

并想用函数发出值:

override suspend fun sendMessage(chat: Chat, message: Message) {
    myflow.emit(message)
}

但是编译器不允许我这样做，有什么解决方法可以解决这个问题吗？

Answer 1

The answer of Animesh Sahu非常正确。您也可以返回 Channel作为流(参见 consumeAsFlow 或 asFlow 上的 BroadcastChannel )。
但是还有一个东西叫 StateFlow Kotlin 团队目前正在开发中，部分目的是实现类似的行为，尽管它何时准备就绪尚不清楚。
编辑: StateFlow 和 SharedFlow 已作为稳定 API ( https://blog.jetbrains.com/kotlin/2020/10/kotlinx-coroutines-1-4-0-introducing-stateflow-and-sharedflow/ ) 的一部分发布。当在异步执行上下文中需要状态管理时，可以并且应该使用这些工具。