d

Modules/BusX/Bus/src/Bus.Debounce.swift

@@ -0,0 +1,31 @@
+import Combine
+
+public extension Bus {
+  final class Debounce<Src, Dst> {
+    let v = PassthroughSubject<Src, Never>()
+    var subscriptions = [AnyCancellable]()
+
+    init(
+      _ handler: @escaping ((Src) -> Dst?),
+      _ sec: Double,
+      _ src: String,
+      _ dst: String
+    ) {
+      // Вход.
+      Bus.receiveSync(
+        [src],
+        { [weak self] _, v in self?.v.send(v) },
+        &subscriptions
+      )
+      // Выход.
+      Bus.sendSync(
+        dst,
+        v
+          .debounce(for: .seconds(sec), scheduler: DispatchQueue.main)
+          .compactMap { (v: Src) in handler(v) }
+          .eraseToAnyPublisher(),
+        &subscriptions
+      )
+    }
+  }
+}

Modules/BusX/Bus/src/Bus.Delay.swift

@@ -0,0 +1,31 @@
+import Combine
+
+public extension Bus {
+  final class Delay<Src, Dst> {
+    let v = PassthroughSubject<Src, Never>()
+    var subscriptions = [AnyCancellable]()
+
+    init(
+      _ handler: @escaping ((Src) -> Dst?),
+      _ sec: Double,
+      _ src: String,
+      _ dst: String
+    ) {
+      // Вход.
+      Bus.receiveSync(
+        [src],
+        { [weak self] _, v in self?.v.send(v) },
+        &subscriptions
+      )
+      // Выход.
+      Bus.sendSync(
+        dst,
+        v
+          .delay(for: .seconds(sec), scheduler: DispatchQueue.main)
+          .compactMap { (v: Src) in handler(v) }
+          .eraseToAnyPublisher(),
+        &subscriptions
+      )
+    }
+  }
+}

Modules/BusX/Bus/src/Bus.Sync.swift

@@ -5,7 +5,7 @@ public extension Bus {
     let v = PassthroughSubject<Src, Never>()
     var subscriptions = [AnyCancellable]()
 
-    public init(
+    init(
       _ handler: @escaping ((Src) -> Dst?),
       _ src: String,
       _ dst: String