d

src/Bus.Processor.swift

@@ -0,0 +1,16 @@
+import Combine
+
+public extension Bus {
+  final class Processor<Src, Dst> {
+    var subscriptions = [AnyCancellable]()
+
+    public init(
+      _ keyIn: String,
+      _ keyOut: String,
+      _ handler: @escaping ((Src) -> Dst?),
+      opt: [Option] = []
+    ) {
+      Bus.process(keyIn, keyOut, handler, opt: opt, sub: &subscriptions)
+    }
+  }
+}