Swift Combine — Subject Publishers（PassthroughSubject CurrentValueSubject）

本文主要介绍一下Subject，Subject 本身也是一个 Publisher，其定义如下：

public protocol Subject<Output, Failure> : AnyObject, Publisher {func send(_ value: Self.Output)func send(completion: Subscribers.Completion<Self.Failure>)func send(subscription: any Subscription)
}

从定义可以看到，Subject 暴露了三个 send 方法，外部调用者可以通过这些方法来主动地发布 output 值、failure 事件、 finished 事件以及subscription。

Combine 内置提供了两种常用的 Subject 类型，分别是 PassthroughSubject 和 CurrentValueSubject，下面来分别看一下。

PassthroughSubject

PassthroughSubject是Combine框架中的一种Subject具体类型，它不持有任何值，将自己接收到的任何值简单的传递给下游的Subscriber。

当我们要创建一个PassthroughSubject时，需要指定要发送的值的类型，然后使用send方法发送，任何的Subscriber都会收到这个值。因为它本身不持有值，所以如果下游没有Subscriber，那么这个值将废弃了。

  func testPassthroughSubjectPublisher() {let publish2 = PassthroughSubject<String, Error>()publish2.send("1")publish2.sink { completion inswitch completion {case .finished:print("---> Finished")case .failure(let error):print("---> Error: \(error.localizedDescription)")}} receiveValue: { value inprint("---> value is: \(value)")}.store(in: &cancellable)publish2.send("2")publish2.send(completion: .finished)}

上面代码中创建了PassthroughSubject实例publish2，并通过sink方法添加了订阅者，订阅后，随后通过send方法发送了2和.finished事件，sink方法中对应的输出都正常。但是在添加sink方法之前发送的send("1")没有任何输出，就像上面说的，发送的时候还没有任何订阅者，发送的值就直接抛弃了。

输出结果：

---> value is: 2
---> Finished

作为Subject的具体实现，PassthroughSubject提供了一种方便的方法，使现有的命令式代码适应Combine模型。

CurrentValueSubject

Currentvaluessubject是Combine框架中的一种Subject具体类型。它可以保存单个值，并在设置新值时向任何订阅者发布新值。
Currentvaluessubject在初始化的时候需要设置一个初始值。

let publisher = CurrentValueSubject<String, Error>("one")

当有订阅者订阅的时候会立即发送这个值。下面代码中当初始化CurrentValueSubjectViewModel的时候，则会直接输出“—> value is: one”

class CurrentValueSubjectViewModel: ObservableObject {init() {setUpPublisher()}func setUpPublisher() {let publisher = CurrentValueSubject<String, Error>("one")let cancelable = publisher.sink { completion inswitch completion {case .finished:print("---> Finished")case .failure(let error):print("---> Error: \(error.localizedDescription)")}} receiveValue: { value inprint("---> value is: \(value)")}}
}

下面代码中，在viewModel中实例化了一个CurrentValueSubject，并添加了subscriber，在SwiftUI界面添加了三个按钮，用来发送数据。

在发送数据的时候，可以通过send方法，也可以通过直接设置value的方法，效果都是一样的。

class CurrentValueSubjectViewModel: ObservableObject {private var cancellable = Set<AnyCancellable>()let publisher = CurrentValueSubject<String, Error>("one")init() {setUpPublisher()}func setUpPublisher() {publisher.sink { completion inswitch completion {case .finished:print("---> Finished")case .failure(let error):print("---> Error: \(error.localizedDescription)")}} receiveValue: { value inprint("---> value is: \(value)")}.store(in: &cancellable)}func sendMessage() {publisher.send("Hello World")publisher.value = "Swift Combine"}func sendError() {publisher.send(completion: .failure(NetworkError.invalidURL))}func sendFinished() {publisher.send(completion: .finished)}}struct CurrentValueSubjectDemo: View {@StateObject private var viewModel = CurrentValueSubjectViewModel()var body: some View {VStack {Button("Send Message") {viewModel.sendMessage()}Button("Send Finished") {viewModel.sendFinished()}Button("Send Error") {viewModel.sendError()}}.buttonStyle(BorderedProminentButtonStyle())}
}

当点击按钮时，输出如下：
在这里插入图片描述

关于Subject生命周期

Subject是有生命周期的，放发送了completion后（不管是finished还是error），Subject都不会再发送任何新值。

就上面的CurrentValueSubject为例，在发送一个value之后，就发送finished，然后在发送value就无效了。
在这里插入图片描述
PassthroughSubject亦是如此。所以当使用PassthroughSubject或CurrentValueSubject时，重要的是要考虑生命周期，并在明显没有任何值发送时关闭Subject。