概述 在 Combine 框架中，发布者是一种符合 协议的类型。它负责为订阅者提供价值流。  协议定义了两个关联类型：  和  ，分别表示发布者可以发出的值的类型和可以抛出的错误的类型。 Publisher Publisher Output Failure 发布者可以随时间发出一个或多个值，也可以完成或失败。当订阅者订阅发布者时，发布者调用订阅者的 方法并向其传递一个 对象，订阅者可以使用该对象来控制值的流动。订阅者也可以调用发布者的 方法来接收新值。 receive(subscription:) Subscription receive(_:)  Combine 框架提供了一些内置的发布器，例如  、   、   、  和  ，可以用来创建各种类型的发布器。此外，您可以通过遵守 协议并实现所需的方法来创建自己的自定义发布者。 Just Fail Empty Deferred Sequence Publisher 发布者也可以组合在一起以创建更复杂的管道。 Combine 框架提供了许多可用于修改和合并发布者的内置运算符，例如  、   、   、   、  和  。这些运算符由 者协议扩展提供，可以在任何发布者上调用。 map filter reduce flatMap zip merge Publisher 现在我想为您提供一些我在我的项目中使用的有用的发布者。 重复计时器发布者 要在 Swift 中实现使用具有自定义间隔的重复计时器的发布者，您可以使用 Foundation 框架中的 类。以下是如何执行此操作的示例： Timer   符合 协议： RepeatingTimeSubscription Subscription   private class RepeatingTimerSubscription<S: Subscriber>: Subscription where S.Input == Void { private let interval: TimeInterval private let queue: DispatchQueue private var subscriber: S? private var timer: Timer? init(interval: TimeInterval, queue: DispatchQueue, subscriber: S) { self.interval = interval self.queue = queue self.subscriber = subscriber } func request(_ demand: Subscribers.Demand) { timer?.invalidate() timer = Timer.scheduledTimer( withTimeInterval: interval, repeats: true ) { [weak self] _ in self?.queue.async { _ = self?.subscriber?.receive() } } } func cancel() { timer?.invalidate() timer = nil subscriber = nil } }   符合 协议： RepeatingTimePublisher Publisher   import Foundation import Combine final class RepeatingTimerPublisher: Publisher { typealias Output = Void typealias Failure = Never private let interval: TimeInterval private let queue: DispatchQueue init(interval: TimeInterval, queue: DispatchQueue = .main) { self.interval = interval self.queue = queue } func receive<S>(subscriber: S) where S: Subscriber, Failure == S.Failure, Output == S.Input { let subscription = RepeatingTimerSubscription( interval: interval, queue: queue, subscriber: subscriber ) subscriber.receive(subscription: subscription) } } 要使用此发布者，您可以创建它的实例并使用 协议的 方法订阅它。 Publisher sink 例如：   private var cancellable: AnyCancellable? func subscribeOnTimer(interval: TimeInterval) { let publisher = RepeatingTimerPublisher(interval: interval) cancellable = publisher.sink { print("Timer fired!") } } //TEST THE METHOD subscribeOnTimer(interval: 5.0) 这将打印“定时器已触发！”每 5 秒。您可以通过对 方法返回的 对象调用 方法来取消订阅。 sink AnyCancellable cancel 例如：   deinit { cancellable?.cancel() } 长轮询发布者 要在 Swift 中使用 Combine 框架实现长轮询，您可以创建一个发布者，它以指定的时间间隔发出网络请求，并将响应作为输出返回。以下是如何执行此操作的示例： 失败案例的自定义错误枚举。   enum CustomError: Error { case invalidResponse case invalidDecoding case error }   符合 协议： LongPollingSubscription Subscription   private class LongPollingSubscription<S: Subscriber, Output: Decodable>: Subscription where S.Input == Output, S.Failure == CustomError { private let url: URL private let interval: TimeInterval private let decoder: JSONDecoder private var subscriber: S? private var timer: Timer? private var task: URLSessionDataTask? init( url: URL, interval: TimeInterval, subscriber: S, decoder: JSONDecoder = JSONDecoder() ) { self.url = url self.interval = interval self.subscriber = subscriber self.decoder = decoder } func request(_ demand: Subscribers.Demand) { timer?.invalidate() timer = Timer.scheduledTimer( withTimeInterval: interval, repeats: true ) { [weak self] _ in self?.makeRequest() } makeRequest() } func cancel() { timer?.invalidate() timer = nil task?.cancel() task = nil subscriber = nil } private func makeRequest() { task = URLSession.shared.dataTask(with: url) { [weak self] data, response, error in guard let self else { return } if let error = error as? S.Failure { self.subscriber?.receive( completion: .failure(error) ) return } guard let data else { self.subscriber?.receive( completion: .failure(.invalidResponse) ) return } do { let output = try self.decoder.decode( Output.self, from: data ) _ = self.subscriber?.receive(output) } catch { self.subscriber?.receive( completion: .failure(.invalidDecoding) ) } } task?.resume() } }   符合 协议： LongPollingPublisher Publisher   final class LongPollingPublisher<Output: Decodable>: Publisher { typealias Failure = CustomError private let url: URL private let interval: TimeInterval init(url: URL, interval: TimeInterval) { self.url = url self.interval = interval } func receive<S>(subscriber: S) where S: Subscriber, Failure == S.Failure, Output == S.Input { let subscription = LongPollingSubscription( url: url, interval: interval, subscriber: subscriber ) subscriber.receive(subscription: subscription) } }   意味着您可以使用任何符合 协议的通用类型的响应。 <Output: Decodable> Decodable 为了进行测试，您需要创建一个符合 的模型。我使用 的公共 API。 Decodable https://pixabay.com/api 让它成为 PhotoResponse 结构：   struct PhotoResponse: Decodable { struct Photo: Decodable { let user: String let id: Int let largeImageURL: String } let hits: [Photo] let total: Int } 要使用此发布者，您可以创建它的实例并使用 协议的 方法订阅它。例如： Publisher sink   private var cancellable: AnyCancellable? private func pollingTest() { let url = URL(string: "https://pixabay.com/api/?key={your_key}")! let publisher = LongPollingPublisher<PhotoResponse>( url: url, interval: 5.0 ) cancellable = publisher.sink(receiveCompletion: { completion in switch completion { case .finished: print("Completed") case .failure(let error): print("Error: \(error)") } }, receiveValue: { response in print("Received response: \(response)") }) } //TEST THE METHOD pollingTest() 还有一件事 可以使用 Swift 中的 Combine 框架创建许多有用的自定义发布者。这里有一些例子：    ：当指定通知发布到 时发出值的发布者。您可以使用此发布者对系统或特定于应用程序的事件做出反应，例如设备轮换或网络状态更改。 NotificationCenterPublisher NotificationCenter    ：在显示或隐藏键盘时发出值的发布者。当键盘显示或关闭时，您可以使用此发布器调整视图的布局。 KeyboardPublisher    ：当用户的位置发生变化时发出值的发布者。此发布者可用于跟踪用户的位置并根据他们的位置执行操作。 CoreLocationPublisher    ：当  （例如 UIButton 或 UITextField）上发生指定事件时发出值的发布者。这可用于以反应方式处理用户交互。 UIControlEventPublisher UIControl 这些只是可以使用 Combine 框架创建的自定义发布者类型的几个例子。关键是了解您的应用程序的要求，并使用框架提供的可用构建块来创建满足这些要求的发布者。 综上所述 最后，需要注意的是，Combine 框架使用函数式反应式编程范式，这是一种随时间处理事件流的编程模型。发布者以及订阅者和运营商是此范例的核心构建块，它们使创建复杂且响应迅速的应用程序变得容易。

This story contains new, firsthand information uncovered by the writer.

Read My Stories

該音頻是用故事的原始語言製作的！

Swift 中有用的发布者：基本指南

About Author

註釋

標籤

这篇文章刊登在

Related Stories

数字游民请注意：您需要了解泰国新推出的 DTV 签证

想赢得 HackerNoon 写作比赛吗？以下是 #crypto-api 比赛获奖者的推荐

Floki 的 Valhalla 成为印度环斯里兰卡赛事联合赞助商

HackerNoon Decoded: The Top 10 Countries Where HackerNoon Is the Most Active

数字游民请注意：您需要了解泰国新推出的 DTV 签证

想赢得 HackerNoon 写作比赛吗？以下是 #crypto-api 比赛获奖者的推荐

Floki 的 Valhalla 成为印度环斯里兰卡赛事联合赞助商

HackerNoon Decoded: The Top 10 Countries Where HackerNoon Is the Most Active

Light-Mode

Classic

Newspaper

Dark-Mode

Neon Noir

Minty

HN StartUps