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
发送时,才会将值转发给订阅者。新的订阅者在接收到事件时才会收到值。