组合多个流量并在任何流动变化时发射

Question

我很难理解为什么流动在我的应用中无法正常工作。

总共有三个流。前两个流都代表用户可以更改的单个值。它们用乘数式插曲保存，并定义如下。

fun flowA() = settings.getLongOrNullFlow(flowAKey).map { /* compute value */ }
fun flowB() = settings.getStringOrNullFlow(flowBKey).map { /* compute value */ }

第三个流是sqldelight查询，该查询取决于前两个流的值。目前，此流量如下。

fun flowC() = flowA().combine(flowB()) { (a, b) -> Pair(a, b) }
    .flapMapLatest { (a, b) ->
        queries.select(a, b).asFlow().mapToList().map { /* compute final value */ }
    }

当收集UI中的流量时，所有内容都按预期的是最初的发射，但不会随后发射。仅更改第一个或第二个流才会发出新值。当将条目添加到数据库中时，没有什么新发射（应该从sqldelight流量并传播）。看到这种变化的唯一方法是更新两个首先流中的任何一个，因此最后一个流程再次运行。

如何构造流程，以使sqldelight流程在接收新值时以及两个流程取决于更改时都会发出。

它可能与flatmaplatest有关，因为它仅在原始流动变化时会产生新的流程。但是我不确定如何在块中返回一些也会导致其发射的东西。

这就是最终在ViewModel中为UI收集的流程的方式。

class ViewModel(private val dataRepository: DataRepository) : ViewModel() {
    val data =
        dataRepository.flowC().stateIn(
            scope = viewModelScope,
            started = SharingStarted.Eagerly,
            initialValue = emptyList(),
        )
}

如果有什么尚不清楚的话。谢谢！