share/muticast
1. share()
share()let sharedPublisher = publisher.share()
sharedPublisher.sink { value in print("Subscriber 1: \(value)") }
sharedPublisher.sink { value in print("Subscriber 2: \(value)") }2. multicast
multicastlet subject = PassthroughSubject<Int, Never>()
let multicastPublisher = publisher.multicast(subject: subject)
multicastPublisher.sink { value in print("Subscriber 1: \(value)") }
multicastPublisher.sink { value in print("Subscriber 2: \(value)") }
// 手动连接以启动数据流
let connection = multicastPublisher.connect()
// 断开连接(可选)
connection.cancel()选择哪个?
Last updated