Combine 中 CurrentValueSubject 和 PassthroughSubject 的区别

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 之前,有两个重要的概念需要简要介绍一下: 观察者模式 响应式编程 观察者模式 观察者模...
    没八阿哥的程序阅读 9,129评论 2 21
  • 简介 Combine是Apple在2019年WWDC上推出的一个新框架。该框架提供了一个声明性的Swift API...
    云天涯丶阅读 24,574评论 5 22
  • 响应式异步编程的抽象和特点: 异步操作在合适的时机发布事件,这些事件带有数据,使用一个或多个操作来处理这些事件以及...
    jancywen阅读 532评论 0 0
  • 前言 “一个随时间处理数据的声明式的 Swift API。”Combine 苹果采用的一种函数响应式编程的库,类似...
    Lcr111阅读 1,516评论 0 2
  • 1、Publisher被观察者 Publisher是一个protocol,是Combine的核心;publishe...
    Joshua666阅读 1,161评论 0 0