概述 在 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

扬帆起航：利用数据湖开发生产级 RAG 应用程序

点击赚钱：Telegram 可能会在 Solana 之前吸引下一个 100 亿加密用户

架构师指南：构建 AI/ML 数据湖参考架构

比特币 UTXO 模型，为独特的生态系统提供动力

扬帆起航：利用数据湖开发生产级 RAG 应用程序

点击赚钱：Telegram 可能会在 Solana 之前吸引下一个 100 亿加密用户

架构师指南：构建 AI/ML 数据湖参考架构

比特币 UTXO 模型，为独特的生态系统提供动力

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps