From b67ed0c593d4de064c386bcfd9de3bc0f2238df3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=9C=D0=B8=D1=85=D0=B0=D0=B8=D0=BB=20=D0=9A=D0=B0=D0=BF?= =?UTF-8?q?=D0=B5=D0=BB=D1=8C=D0=BA=D0=BE?= Date: Sun, 31 Dec 2023 19:58:55 +0300 Subject: [PATCH] d --- Modules/BusX/Bus/src/Bus.Async.swift | 31 +++++++++++++++ Modules/BusX/Bus/src/Bus.Aux.swift | 19 +-------- Modules/BusX/Bus/src/Bus.Processor.swift | 23 ----------- Modules/BusX/Bus/src/Bus.Sync.swift | 29 ++++++++++++++ Modules/BusX/Bus/src/Bus.swift | 50 ++++-------------------- Modules/MeetupIdX/src/MeetupId.V.swift | 2 +- 6 files changed, 70 insertions(+), 84 deletions(-) create mode 100644 Modules/BusX/Bus/src/Bus.Async.swift delete mode 100644 Modules/BusX/Bus/src/Bus.Processor.swift create mode 100644 Modules/BusX/Bus/src/Bus.Sync.swift diff --git a/Modules/BusX/Bus/src/Bus.Async.swift b/Modules/BusX/Bus/src/Bus.Async.swift new file mode 100644 index 0000000..111df2b --- /dev/null +++ b/Modules/BusX/Bus/src/Bus.Async.swift @@ -0,0 +1,31 @@ +import Combine + +public extension Bus { + final class Async { + let v = PassthroughSubject() + var subscriptions = [AnyCancellable]() + + public init( + _ handler: @escaping ((Src) -> Dst?), + _ src: String, + _ dst: String + ) { + // Вход. + Bus.receiveSync( + [src], + { [weak self] _, v in self?.v.send(v) }, + &subscriptions + ) + // Выход. + Bus.sendSync( + dst, + v + .compactMap { (v: Src) in handler(v) } + // Асинхронно. + .receive(on: DispatchQueue.main) + .eraseToAnyPublisher(), + &subscriptions + ) + } + } +} diff --git a/Modules/BusX/Bus/src/Bus.Aux.swift b/Modules/BusX/Bus/src/Bus.Aux.swift index 79804e1..01c0d98 100644 --- a/Modules/BusX/Bus/src/Bus.Aux.swift +++ b/Modules/BusX/Bus/src/Bus.Aux.swift @@ -1,5 +1,5 @@ public extension Bus { - /// Пропускаем далее предоставленный ключ. + /// Пропускаем далее единственный ключ. static func convertKeyValue( _ key: String, _ v: (key: String, value: Any) @@ -13,7 +13,7 @@ public extension Bus { return (key, value) } - /// Пропускаем далее предоставленные ключи. + /// Пропускаем далее множество ключей. static func convertKeyValue( _ keys: Set, _ v: (key: String, value: Any) @@ -26,19 +26,4 @@ public extension Bus { } return (v.key, value) } - - /// Обрабатываем. - static func processKeysValue( - _ v: (key: String, value: Any), - _ keysIn: Set, - _ handler: @escaping ((Src) -> Dst?) - ) -> Dst? { - guard - keysIn.contains(v.key), - let vIn = v.value as? Src - else { - return nil - } - return handler(vIn) - } } diff --git a/Modules/BusX/Bus/src/Bus.Processor.swift b/Modules/BusX/Bus/src/Bus.Processor.swift deleted file mode 100644 index c67d02e..0000000 --- a/Modules/BusX/Bus/src/Bus.Processor.swift +++ /dev/null @@ -1,23 +0,0 @@ -import Combine - -public extension Bus { - final class Processor { - var subscriptions = [AnyCancellable]() - - public init( - _ handler: @escaping ((Src) -> Dst?), - _ keyIn: String, - _ keyOut: String - ) { - Bus.processSync([keyIn], keyOut, handler, &subscriptions) - } - - public init( - _ handler: @escaping ((Src) -> Dst?), - _ keysIn: Set, - _ keyOut: String - ) { - Bus.processSync(keysIn, keyOut, handler, &subscriptions) - } - } -} diff --git a/Modules/BusX/Bus/src/Bus.Sync.swift b/Modules/BusX/Bus/src/Bus.Sync.swift new file mode 100644 index 0000000..4e5b317 --- /dev/null +++ b/Modules/BusX/Bus/src/Bus.Sync.swift @@ -0,0 +1,29 @@ +import Combine + +public extension Bus { + final class Sync { + let v = PassthroughSubject() + var subscriptions = [AnyCancellable]() + + public init( + _ handler: @escaping ((Src) -> Dst?), + _ src: String, + _ dst: String + ) { + // Вход. + Bus.receiveSync( + [src], + { [weak self] _, v in self?.v.send(v) }, + &subscriptions + ) + // Выход. + Bus.sendSync( + dst, + v + .compactMap { (v: Src) in handler(v) } + .eraseToAnyPublisher(), + &subscriptions + ) + } + } +} diff --git a/Modules/BusX/Bus/src/Bus.swift b/Modules/BusX/Bus/src/Bus.swift index 3a9b236..33ae467 100644 --- a/Modules/BusX/Bus/src/Bus.swift +++ b/Modules/BusX/Bus/src/Bus.swift @@ -10,7 +10,7 @@ public enum Bus { } public extension Bus { - /// Асинхронно обрабатывать входящие события из шины. + /// Асинхронно обрабатываем входящие события из шины. static func receiveAsync( _ keys: Set, _ handler: @escaping ((String, T) -> Void), @@ -23,7 +23,7 @@ public extension Bus { .store(in: &subscriptions) } - /// Синхронно обрабатывать входящие события из шины. + /// Синхронно обрабатываем входящие события из шины. static func receiveSync( _ keys: Set, _ handler: @escaping ((String, T) -> Void), @@ -35,19 +35,10 @@ public extension Bus { .store(in: &subscriptions) } - /// Асинхронно отправлять события из узла в шину. - static func sendAsync( - _ key: String, - _ node: AnyPublisher, - _ subscriptions: inout [AnyCancellable] - ) { - node - .receive(on: DispatchQueue.main) - .sink { v in e.send((key, v)) } - .store(in: &subscriptions) - } - - /// Синхронно отправлять события из узла в шину. + /// Синхронно отправляем события из узла в шину. + /// + /// Для асинхронной отправки достаточно добавить оператор `receive(on:)` + /// в цепочке параметра `node` static func sendSync( _ key: String, _ node: AnyPublisher, @@ -58,35 +49,8 @@ public extension Bus { .store(in: &subscriptions) } - /// Синхронно отправить событие в шину один раз. + /// Единоразово синхронно отправляем событие в шину. static func send(_ key: String, _ value: Any) { e.send((key, value)) } } - -public extension Bus { - static func processAsync( - _ keysIn: Set, - _ keyOut: String, - _ handler: @escaping ((Src) -> Dst?), - _ subscriptions: inout [AnyCancellable] - ) { - e - .compactMap { processKeysValue($0, keysIn, handler) } - .receive(on: DispatchQueue.main) - .sink { vOut in Self.e.send((keyOut, vOut)) } - .store(in: &subscriptions) - } - - static func processSync( - _ keysIn: Set, - _ keyOut: String, - _ handler: @escaping ((Src) -> Dst?), - _ subscriptions: inout [AnyCancellable] - ) { - e - .compactMap { processKeysValue($0, keysIn, handler) } - .sink { vOut in Self.e.send((keyOut, vOut)) } - .store(in: &subscriptions) - } -} diff --git a/Modules/MeetupIdX/src/MeetupId.V.swift b/Modules/MeetupIdX/src/MeetupId.V.swift index 99dd1b7..125e2ab 100644 --- a/Modules/MeetupIdX/src/MeetupId.V.swift +++ b/Modules/MeetupIdX/src/MeetupId.V.swift @@ -8,7 +8,7 @@ extension MeetupId { @StateObject var join = BusUI.Button(K.join) @StateObject var textField = BusUI.TextField(K.textApp, K.textUI) let processors: [Any] = [ - Bus.Processor(shouldEnableJoin, K.M, K.isJoinAvailable), + Bus.Sync(shouldEnableJoin, K.M, K.isJoinAvailable), MeetupId.Debounce(0.2, formatId, K.textUI, K.textApp), MeetupId.Delay(5, finishLoading, K.isLoading, K.finishLoading), ]