Aperçu  Dans l'infrastructure Combine, un éditeur est un type conforme au protocole   . Il est chargé de fournir un flux de valeurs aux abonnés. Le protocole   définit deux types associés :   et   , qui indiquent respectivement les types de valeurs que l'éditeur peut émettre et les types d'erreurs qu'il peut lancer. Publisher Publisher Output Failure  Un éditeur peut émettre une ou plusieurs valeurs au fil du temps, et il peut également se terminer ou échouer. Lorsqu'un abonné s'abonne à un éditeur, l'éditeur appelle la méthode   de l'abonné et lui transmet un objet   , que l'abonné peut utiliser pour contrôler le flux de valeurs. L'abonné peut également appeler la méthode   sur l'éditeur pour recevoir de nouvelles valeurs. receive(subscription:) Subscription receive(_:)  Le framework Combine fournit un certain nombre d'éditeurs intégrés, tels que   ,   ,   ,   et   , qui peuvent être utilisés pour créer différents types d'éditeurs. De plus, vous pouvez créer vos propres éditeurs personnalisés en vous conformant au protocole   et en implémentant les méthodes requises. Just Fail Empty Deferred Sequence Publisher  Les éditeurs peuvent également être composés ensemble pour créer des pipelines plus complexes. Le framework Combine fournit un certain nombre d'opérateurs intégrés qui peuvent être utilisés pour modifier et combiner des éditeurs, tels que   ,   ,   ,   ,   et   . Ces opérateurs sont fournis par l'extension de protocole   et peuvent être appelés sur n'importe quel éditeur. map filter reduce flatMap zip merge Publisher  Maintenant, je voudrais vous proposer quelques éditeurs utiles que j'utilise dans mes projets.  Éditeur de minuterie répétitive  Pour implémenter un éditeur qui utilise un minuteur répétitif avec un intervalle personnalisé dans Swift, vous pouvez utiliser la classe   du framework Foundation. Voici un exemple de la façon dont vous pouvez le faire : Timer    est conforme au protocole   : 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 } }    est conforme au protocole   : 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) } }  Pour utiliser cet éditeur, vous pouvez en créer une instance et vous y abonner à l'aide de la   du récepteur du protocole   . sink Publisher  Par example:   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)  Cela affichera "Minuterie déclenchée !" toutes les 5 secondes. Vous pouvez annuler l'abonnement en appelant la méthode d'   sur l'objet   renvoyé par la méthode du   . cancel AnyCancellable sink  Par example:   deinit { cancellable?.cancel() }  Éditeur à long sondage  Pour implémenter une interrogation longue à l'aide du framework Combine dans Swift, vous pouvez créer un éditeur qui effectue une requête réseau à un intervalle spécifié et renvoie la réponse en sortie. Voici un exemple de la façon dont vous pouvez le faire :  Énumération d'erreur personnalisée pour les cas ayant échoué.   enum CustomError: Error { case invalidResponse case invalidDecoding case error }    est conforme au protocole d'   : 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() } }    est conforme au protocole   : 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) } }    signifie que vous pouvez utiliser n'importe quel type de réponse générique conforme au protocole   . <Output: Decodable> Decodable  Pour les tests, vous devez créer un modèle conforme   . J'utilise une API publique par   . Decodable https://pixabay.com/api  Soit la structure PhotoResponse :   struct PhotoResponse: Decodable { struct Photo: Decodable { let user: String let id: Int let largeImageURL: String } let hits: [Photo] let total: Int }  Pour utiliser cet éditeur, vous pouvez en créer une instance et vous y abonner à l'aide de la   du récepteur du protocole   . Par example: sink Publisher   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()  Encore une chose  Il existe un certain nombre d'éditeurs personnalisés utiles qui peuvent être créés à l'aide du framework Combine dans Swift. Voici quelques exemples:    : un éditeur qui émet des valeurs lorsqu'une notification spécifiée est publiée sur le   . Vous pouvez utiliser cet éditeur pour réagir à des événements spécifiques au système ou à l'application, tels qu'une rotation d'appareil ou un changement d'état du réseau. NotificationCenterPublisher NotificationCenter    : Un éditeur qui émet des valeurs lorsque le clavier est affiché ou masqué. Vous pouvez utiliser cet éditeur pour ajuster la disposition de vos vues lorsque le clavier est présenté ou fermé. KeyboardPublisher    : un éditeur qui émet des valeurs lorsque l'emplacement de l'utilisateur change. Cet éditeur peut être utilisé pour suivre l'emplacement de l'utilisateur et effectuer des actions en fonction de son emplacement. CoreLocationPublisher    : un éditeur qui émet des valeurs lorsqu'un événement spécifié se produit sur un   tel que UIButton ou UITextField. Cela peut être utilisé pour gérer les interactions des utilisateurs de manière réactive. UIControlEventPublisher UIControl  Ce ne sont là que quelques exemples des types d'éditeurs personnalisés qui peuvent être créés à l'aide du framework Combine. La clé est de comprendre les exigences de votre application et d'utiliser les blocs de construction disponibles fournis par le framework pour créer des éditeurs qui répondent à ces exigences.  En conclusion  Enfin, il est important de noter que le framework Combine utilise le paradigme de la programmation réactive fonctionnelle, qui est un modèle de programmation qui traite des flux d'événements au fil du temps. Les éditeurs, ainsi que les abonnés et les opérateurs, sont les éléments de base de ce paradigme, et ils facilitent la création d'applications complexes et réactives.

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

Read My Stories

Cet audio est produit dans la langue originale de l'histoire !

Éditeurs utiles dans Swift : un guide essentiel

About Author

COMMENTAIRES

ÉTIQUETTES

CET ARTICLE A ÉTÉ PARU DANS

Related Stories

La fuite de l'invite du système Claude Sonnet 3.5 : une analyse médico-légale

Libérer la puissance de l’IA. Une revue systématique des techniques de pointe : résumé et introduction

Vous voulez gagner un concours d’écriture HackerNoon ? Voici ce que recommandent les gagnants du concours #crypto-api

Valhalla de Floki se joint en tant que sponsor associé de la tournée indienne au Sri Lanka

La fuite de l'invite du système Claude Sonnet 3.5 : une analyse médico-légale

Libérer la puissance de l’IA. Une revue systématique des techniques de pointe : résumé et introduction

Vous voulez gagner un concours d’écriture HackerNoon ? Voici ce que recommandent les gagnants du concours #crypto-api

Valhalla de Floki se joint en tant que sponsor associé de la tournée indienne au Sri Lanka

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps