android - 可以用多个收集器收集的 Kotlin 流(或类似的东西)

Question

我尝试使用 Kotlin Flow 作为某种消息容器，它应该将此消息传递给所有观察者(收集器)。我不想故意使用 LiveData，因为它需要了解生命周期。

不幸的是，我注意到如果一个收集器从流中收集消息，则其他人无法接收它。

我可以用什么来实现“一进多出”。

Answer 1

您可以使用 StateFlow 或 SharedFlow，它们是 Flow API，使流能够以最佳方式发出状态更新并向多个消费者发出值。

来自文档，可用 here :

StateFlow: is a state-holder observable flow that emits the current and new state updates to its collectors. The current state value can also be read through its value property.

SharedFlow: a hot flow that emits values to all consumers that collect from it. A SharedFlow is a highly-configurable generalization of StateFlow.

将状态流与 View 模型一起使用的简单示例:

class myViewModel() : ViewModel() {

  val messageStateFlow = MutableStateFlow("My inicial awesome message")

}

您可以使用一些范围发出一个新值:

yourScope.launch {
    messageStateFlow.emit("My new awesome message")
}

您可以使用一些范围收集一个值:

yourScope.launch {
    messageStateFlow.collect {
        // do something with your message
    }
}

注意:切勿直接从 launch 或 launchIn 扩展函数中收集 UI 流来更新 UI。即使 View 不可见，这些函数也会处理事件。您可以按照文档的建议使用 repeatOnLifecycle。