swift - Swift Combine:这些多播功能有什么用,我该如何使用它们?
问题描述
我遇到了一些组合问题,在https://developer.apple.com/documentation/combine/publisher中遇到了“与多个订阅者一起工作”部分:
func multicast<S>(() -> S) -> Publishers.Multicast<Self, S>
func multicast<S>(subject: S) -> Publishers.Multicast<Self, S>
但是,当我尝试确认发送给多个订阅者时需要多播的假设时,我发现在尝试此操场代码时不需要这样做(修改自https://github.com/AvdLee/CombineSwiftPlayground/blob/ master/Combine.playground/Pages/Combining%20Publishers.xcplaygroundpage/Contents.swift)(在 Xcode 版本 11.0 beta 3 (11M362v) 中的 10.14.5 上运行):
enum FormError: Error { }
let usernamePublisher = PassthroughSubject<String, FormError>()
let passwordPublisher = PassthroughSubject<String, FormError>()
let validatedCredentials = Publishers.CombineLatest(usernamePublisher, passwordPublisher)
.map { (username, password) -> (String, String) in
return (username, password)
}
.map { (username, password) -> Bool in
!username.isEmpty && !password.isEmpty && password.count > 12
}
.eraseToAnyPublisher()
let firstSubscriber = validatedCredentials.sink { (valid) in
print("First Subscriber: CombineLatest: Are the credentials valid: \(valid)")
}
let secondSubscriber = validatedCredentials.sink { (valid) in
print("Second Subscriber: CombineLatest: Are the credentials valid: \(valid)")
}
// Nothing will be printed yet as `CombineLatest` requires both publishers to have send at least one value.
usernamePublisher.send("avanderlee")
passwordPublisher.send("weakpass")
passwordPublisher.send("verystrongpassword")
这打印:
First Subscriber: CombineLatest: Are the credentials valid: false
Second Subscriber: CombineLatest: Are the credentials valid: false
First Subscriber: CombineLatest: Are the credentials valid: true
Second Subscriber: CombineLatest: Are the credentials valid: true
所以似乎不需要多播来解决多个订阅者。还是我错了?
那么,这些多播功能是做什么用的,我将如何使用它们呢?一些示例代码会很好。
谢谢,
拉斯
解决方案
PassthroughSubject 不是一个很好的测试示例,因为它是一个类并为您提供参考语义。因此,在一个简单的情况下,两个订阅者可以直接订阅它,并在主题发出一个值时同时接收相同的值。
但这里有一个更好的测试用例(灵感来自关于Cocoa With Love的讨论):
let pub1 = Timer.publish(every: 1, on: .main, in: .default).autoconnect()
let sub = CurrentValueSubject<Int,Never>(0)
let scan = sub.scan(10) {i,j in i+j}
pub1.sink { _ in let i = sub.value; sub.value = i+1 }.store(in:&storage)
scan.sink { print("a", $0) }.store(in:&storage)
delay(3) {
scan.sink { print("b", $0) }.store(in:&self.storage)
}
sink
当第二个作为该管道的新订阅者出现时,这给出了一个非常奇怪的结果:
a 10
a 11
a 13
a 16
b 13
a 20
b 17
a 25
b 22
a 31
b 28
a 38
b 35
下沉a
并且b
彼此得到一系列不同的数字,实际上是因为scan
它是一个结构。如果我们希望它们获得相同的数字,我们可以使用多播:
let scan = sub.scan(10) {i,j in i+j}.multicast {PassthroughSubject()}.autoconnect()
这会产生
a 10
a 11
a 13
a 16
a 20
b 20
a 25
b 25
这是连贯的。
但是,这仍然不能证明您需要multicast
,因为您可以通过说.share()
来完成同样的事情。multicast
我不清楚和之间有什么区别share
。
推荐阅读
- visual-studio - 在 Visual Studio 中重定向生成输出
- python - 为什么我需要在 Python/Pytorch 中使用两次导入?
- python - 多行窗口和列表
- javascript - 锁定服务不适用于库脚本 App Script || AppendRow 覆盖数据,因此是 while 循环
- xml - Azure 数据工厂 HTTP 连接器不返回 XML 输出
- rust - SQL 表有主键但报错“Diesel 只支持有主键的表。表错误没有主键”
- google-cloud-platform - BigQuery 到 Kafka 主题
- python - 如何使用 python cv2.SimpleBlobDetector 检测图像中的单个最大点?
- regex - AutoHotKey IfWinExists 不适用于正则表达式
- css - 使用某些字体在输入元素内垂直居中文本的问题