为何multicast(_:)在双订阅者场景下仅触发一次debug打印？

你遇到的情况是：代码里有两个订阅者，但debug: multicast triggered..只打印了一次，按照苹果文档对multicast(_:)的描述，似乎应该为每个订阅者创建新发布者，闭包该触发两次才对？

先看你的代码：

import Foundation
import Combine

var cancellables = Set<AnyCancellable>()
let upstreamPublisher = Range(1...3).publisher.delay(for: 1, scheduler: DispatchQueue.main)

let sharedSubject = CurrentValueSubject<Int, Never>(-1)

// Create a multicast publisher and apply autoconnect
let multicastPublisher = upstreamPublisher
    .multicast({
        print("debug: multicast triggered..")
        return sharedSubject
    })
    .autoconnect()

// Subscriber 1
multicastPublisher
    .sink { value in
        print("Subscriber 1 received value: \(value)")
    }
    .store(in: &cancellables)

// Subscriber 2
multicastPublisher
    .sink { value in
        print("Subscriber 2 received value: \(value)")
    }
    .store(in: &cancellables)

// Output
//debug: multicast triggered..
//Subscriber 1 received value: -1
//Subscriber 2 received value: -1
//Subscriber 1 received value: 1
//Subscriber 2 received value: 1
//Subscriber 1 received value: 2
//Subscriber 2 received value: 2
//Subscriber 1 received value: 3
//Subscriber 2 received value: 3

原因解析 #

• multicast(_:)的闭包不是在每个订阅者订阅时执行，而是在发布者被connect()的时候执行一次。你用了autoconnect()，它会在第一个订阅者订阅时自动调用connect()，所以闭包只触发一次。
• 苹果文档的描述容易产生误解：multicast的核心是让多个订阅者共享同一个上游事件流，它的闭包是用来提供一个共享的Subject，所有订阅者都会订阅这个Subject，而不是各自订阅上游发布者。每个订阅者拿到的是这个共享Subject的订阅，不是新的上游发布者实例。
• 你这里提前创建了sharedSubject并在闭包里返回它，就算闭包能执行多次，也还是同一个Subject实例，但autoconnect()只会触发一次连接，所以闭包只跑一次。如果真的想让每个订阅者对应独立的事件流，你应该把Subject的创建移到闭包里（比如return CurrentValueSubject<Int, Never>(-1)），但这时候multicast就失去了“共享”的意义，而且autoconnect的行为也会变成每个订阅者触发一次连接，闭包才会执行多次——但这显然不是你这段代码想要的效果。

你的代码输出是符合预期的：两个订阅者共享了同一个Subject的事件，包括初始值和上游的所有数据，这正是multicast的设计目的。

内容的提问来源于stack exchange，提问作者Shuaiqing Luo