Swift CombineLatest合并PassthroughSubject首次发值无输出问题

Publishers.CombineLatest的运行规则非常明确：只有当所有参与合并的上游发布者，都至少发送过1个值之后，它才会在任意上游发布新值时，把所有流的最新值打包成元组推给下游。
你当前的代码逻辑里，订阅CombineLatest后第一个发送值的是p1，此时p2还从未输出过任何内容，CombineLatest无法凑齐两个流的最新值，因此不会触发sink回调，只会把p1发来的4暂存为内部记录的p1最新值。直到后续p2发送false时，两个流都有了可读取的最新值，它才会把暂存的4和刚收到的false打包输出，这时候才会看到控制台打印。

根据实际业务需求，选对应方案即可：

方案1：需要每次触发时同时拿到两个流的最新值（保留CombineLatest的元组输出能力） #

核心思路是让两个流在被CombineLatest订阅后，能立刻提供一个值，凑齐第一轮输出的必要条件，后续任意流发新值都会立刻触发回调。
你可以直接把PassthroughSubject替换成自带初始值的CurrentValueSubject，它在被订阅时会第一时间把当前存储的值发给订阅者：

// 替换为带初始值的CurrentValueSubject，初始值根据业务场景设置即可
let p1: CurrentValueSubject<Int, Never> = .init(0)
let p2: CurrentValueSubject<Bool, Never> = .init(false)

var pub1: AnyPublisher<Int, Never> {
    p1.eraseToAnyPublisher()
}

var pub2: AnyPublisher<Bool, Never> {
    p2.eraseToAnyPublisher()
}

var sub: AnyCancellable?
sub = Publishers.CombineLatest(pub1, pub2).sink { output in
    print("output: \(output)")
}

// 订阅完成瞬间就会打印：output: (0, false)
p1.send(4)
// 立刻触发打印：output: (4, false)
p2.send(true)
// 立刻触发打印：output: (4, true)

如果你不想替换Subject类型，也可以用prepend操作符给流补一个前置初始值，效果完全一致：

let p1: PassthroughSubject<Int, Never> = .init()
let p2: PassthroughSubject<Bool, Never> = .init()

var pub1: AnyPublisher<Int, Never> {
    p1.prepend(0).eraseToAnyPublisher() // 补充初始值
}

var pub2: AnyPublisher<Bool, Never> {
    p2.prepend(false).eraseToAnyPublisher() // 补充初始值
}
// 后续CombineLatest订阅逻辑不变

方案2：不需要同时拿到两个流的最新值，仅要求任意流发值就立刻触发响应 #

这种场景下CombineLatest本身就不适用，你可以先把两个流的输出统一为相同类型，再用Publishers.Merge做合并——Merge的逻辑是只要任意上游发值就立刻转发给下游，不需要等待其他流发送内容：

let p1: PassthroughSubject<Int, Never> = .init()
let p2: PassthroughSubject<Bool, Never> = .init()

// 先统一两个流的输出类型，这里用枚举做区分，也可以根据业务选其他统一方式
enum StreamEvent {
    case intFromP1(Int)
    case boolFromP2(Bool)
}

var pub1: AnyPublisher<StreamEvent, Never> {
    p1.map { .intFromP1($0) }.eraseToAnyPublisher()
}

var pub2: AnyPublisher<StreamEvent, Never> {
    p2.map { .boolFromP2($0) }.eraseToAnyPublisher()
}

var sub: AnyCancellable?
sub = Publishers.Merge(pub1, pub2).sink { event in
    print("received event: \(event)")
}

p1.send(4)
// 立刻打印：received event: intFromP1(4)
p2.send(false)
// 立刻打印：received event: boolFromP2(false)

内容的提问来源于stack exchange，提问作者Kelvin Fok