CurrentValueSubject 和 PassthroughSubject 都是 Combine 框架中用于发布数据的 Publisher 类型,但它们在行为和用途上有一些关键的区别。
1. CurrentValueSubject 和 PassthroughSubject 的共同点
- 都是
Publisher,可以向其订阅者发布数据。 - 都属于 Subject 类型,在 Combine 中,
Subject是可以既作为 Publisher 也作为 Subscriber 的对象,允许你手动推送事件(发布数据)。
2. CurrentValueSubject 和 PassthroughSubject 的区别
CurrentValueSubject:
-
类型定义:
CurrentValueSubject<Output, Failure> -
特点:持有一个当前值,并允许你对这个值进行读取和更新。它会始终有一个初始值,并且可以随时通过
send(_:)方法发送新值。 -
行为:
CurrentValueSubject需要一个初始值,因此在创建时必须传入一个初始值。如果没有新的值发送,它会继续向订阅者发布当前的值。 -
初始值:它总是保持一个 当前值,并且可以通过
value属性直接访问当前值,且会始终向新的订阅者发送该值。 -
适用场景:当你需要保持最新的状态或者值,并且确保新的订阅者能立刻收到当前的值时,使用
CurrentValueSubject很合适。
示例:
private let creditSubject = CurrentValueSubject<(), Never>(())
-
creditSubject初始化时会持有()(空元组)作为当前值。 - 每次调用
creditSubject.send(())会更新它的当前值并向订阅者发布新的值。 - 新的订阅者会立刻收到
()这个初始值。
PassthroughSubject:
-
类型定义:
PassthroughSubject<Output, Failure> - 特点:没有初始值。它只是将它接收到的所有值转发给订阅者,而不存储任何值。
-
行为:当你通过
send(_:)方法发送数据时,PassthroughSubject会将数据立即传递给所有的订阅者。它不像CurrentValueSubject那样持有或缓存当前的值。 -
适用场景:当你只关心信号的发送而不需要存储值时,使用
PassthroughSubject。比如说,当你只关心事件的发生,而不需要订阅者知道事件发生时的任何“状态”。
示例:
let pickPhotoResultSubject = PassthroughSubject<PickResult, Never>()
-
pickPhotoResultSubject没有初始值,它只是用来传递PickResult类型的值。 - 每次调用
pickPhotoResultSubject.send(pickResult)会立即将pickResult发送给所有的订阅者。 - 新的订阅者不会立刻收到任何值,只有当数据通过
send(_:)被发布时才会收到数据。
3. 主要区别
| 特性 | CurrentValueSubject |
PassthroughSubject |
|---|---|---|
| 初始值 | 有初始值,必须提供一个初始值 | 没有初始值 |
| 值存储 | 存储当前值,可以通过 value 属性获取当前值 |
不存储任何值,只是转发接收到的值 |
| 订阅行为 | 新的订阅者会收到当前值 | 新的订阅者不会收到任何值,只有在数据发送后才会接收到 |
| 用途 | 用于需要存储并共享当前状态的场景 | 用于单纯的事件通知或信号的转发 |
4. 示例对比:
CurrentValueSubject 示例
// 初始值是 0
private let subject = CurrentValueSubject<Int, Never>(0)
// 订阅者 1
subject.sink(receiveValue: { value in
print("Subscriber 1: \(value)") // 会立即打印 "Subscriber 1: 0"
})
// 发送新的值
subject.send(1)
// 订阅者 2
subject.sink(receiveValue: { value in
print("Subscriber 2: \(value)") // 会打印 "Subscriber 2: 1"
})
-
输出:
Subscriber 1: 0 Subscriber 1: 1 Subscriber 2: 1
PassthroughSubject 示例
// 没有初始值
private let subject = PassthroughSubject<Int, Never>()
// 订阅者 1
subject.sink(receiveValue: { value in
print("Subscriber 1: \(value)")
})
// 发送新的值
subject.send(1)
// 订阅者 2
subject.sink(receiveValue: { value in
print("Subscriber 2: \(value)")
})
-
输出:
Subscriber 1: 1 Subscriber 2: 1
在这个例子中,PassthroughSubject 并没有提供初始值,而是当事件通过 send 发送时,才会将值转发给订阅者。新的订阅者在接收到事件时才会收到值。









网友评论