如何让Combine中flatMap内部publisher完成时触发整个流的完成事件

Combine 流的完成规则为：只有上游 Publisher 主动发送 .finished 事件时，整个下游流才会触发完成回调。你使用的 CurrentValueSubject 是可长期存活的主动型 Publisher，没有手动触发的情况下永远不会主动发送完成事件，因此哪怕 flatMap 包裹的内部 Publisher 全部执行完成，整个流仍会保持监听状态等待 Subject 发送新值，不会输出 finished 日志。

如果你的需求是仅处理 Subject 发出的第一个值，处理完成后就结束流，直接在 Subject 后追加 .first() 操作符即可：

subject
    .first() // 新增这行代码
    .flatMap({ _ in a() })
    .flatMap({ _ in b() })
    .print()
    .sink(receiveCompletion: { _ in
        tempBag.removeAll()
    }, receiveValue: {  })
    .store(in: &tempBag)

.first() 操作符会在接收到上游发出的第一个值后，自动终止对上游的监听，等两个 flatMap 的内部 Publisher 全部执行完成后，整个流就会正常触发 .finished 事件，输出你预期的日志。

如果需要适配其他场景可以选择对应方案：

• 需要接收上游前 N 个值后结束流：使用 .prefix(N) 操作符，逻辑和 .first() 一致，仅接收指定数量的值后自动终止流
• 需要在自定义时机结束流：在对应逻辑位置调用 subject.send(completion: .finished)，主动给根节点 Subject 发送完成事件，即可终止整个流

内容的提问来源于stack exchange，提问作者Andrii Moisol