美文网首页
Combine 中 CurrentValueSubject 和

Combine 中 CurrentValueSubject 和

作者: 大成小栈 | 来源:发表于2024-12-18 21:20 被阅读0次

CurrentValueSubjectPassthroughSubject 都是 Combine 框架中用于发布数据的 Publisher 类型,但它们在行为和用途上有一些关键的区别。

1. CurrentValueSubjectPassthroughSubject 的共同点

  • 都是 Publisher,可以向其订阅者发布数据。
  • 都属于 Subject 类型,在 Combine 中,Subject 是可以既作为 Publisher 也作为 Subscriber 的对象,允许你手动推送事件(发布数据)。

2. CurrentValueSubjectPassthroughSubject 的区别

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

相关文章

网友评论

      本文标题:Combine 中 CurrentValueSubject 和

      本文链接:https://www.haomeiwen.com/subject/rvjdejtx.html