android - Kotlin Flow 如何组合两个流并仅在第一个流发送元素时发出结果

Question

有两个流:FlowA 和 FlowB。

我想组合它们并仅在 FlowA 发出元素时从 FlowA 获取最新元素并从 FlowB 获取最新元素。这就像组合 FlowA 和 FlowB，但仅在 FlowA 发出元素时触发组合流。

Answer 1

如果 flowA 不包含重复元素，或者如果您可以“不触发”A 的重复元素，则可以使用 zip 实现您想要的效果和 distinctUntilChangedBy像这样:

val flowA = flowOf("a", "b", "c")
val flowB = flowOf(1, 2, 3)

val resultFlow = flowA.zip(flowB)
                      .distinctUntilChangedBy { (a, _) -> a }
                      .map { (a, b) -> TODO("combine a and b") }

另一种选择是从 B 中创建一个 StateFlow 并在需要时访问最新值(但它需要一个范围来收集状态中的 B，因此它使这段代码变得半热):

val flowA = flowOf("a", "b", "c")
val flowB = flowOf(1, 2, 3)

val stateB = flowB.stateIn(someScope)
val resultFlow = flowA.map { a -> 
    val b = stateB.value
    TODO("combine a and b")
}