将两个状态流组合成一个流

Question

我目前正在尝试将两个流组合在一起，并使用该结果将其显示为Android中的构图视图。我当前这样的初始化：

private var flowA: MutableStateFlow<String?> = MutableStateFlow(null)
private var flowB: MutableStateFlow<String?> = MutableStateFlow(null)

var combinedFlows: Flow<Pair<String?, String?>> =
    flowA.combine(flowB) {a, b ->
        Pair(a, b)
    }

像这样发射：

// Some logic to create string
flowA.emit("New String") 

// More logic to create another string
flowB.emit("Another New String")

在撰写视图中，我正在收集这样的收集：

var pairStrings = viewModel.pairStrings.collectAsState()

当我从flowa 和flowb发出时，组合流从未发出任何数据 。 。我在这里缺少什么吗？

-edit-

这是在视图模型中：

val pairStrings: StateFlow<Pair<String?, String?>> = combinedFlows
    .stateIn(
        scope = viewModelScope,
        initialValue = Pair(null,null),
        started = SharingStarted.Eagerly,
    )

Answer 1

您没有提供太多信息，但是您需要运行/订阅组合流程。我认为您需要执行以下操作：

val combinedFlows = flowA.combine(flowB) { a, b ->
    a to b // will emit a Pair with the latest value of flowA and flowB
}.shareIn(viewModelScope, SharingStarted.WhileSubscribed())

sharein操作员在单独的coroutine中运行上游流程。这样做，您将能够消耗流量。
您需要传递coroutinescope，假设您在ViewModel中进行此调用（应该是最好的地方），则可以使用view> viewModelsCope。您还需要传递sharingState，该>将确定在启动和停止共享时控制的策略。在这种情况下，我正在使用whilesubscribed，它在最后一个订户消失时立即停止流动。