From 945eb221209a6c3c00b2f0fcbbc7e19b343ee9d9 Mon Sep 17 00:00:00 2001
From: Jake Zerrer <him@jakezerrer.com>
Date: Fri, 7 Nov 2025 15:42:03 -0500
Subject: Add new instrument

---
 src/unheard/midi.clj | 23 ++++++++++++-----------
 1 file changed, 12 insertions(+), 11 deletions(-)

(limited to 'src/unheard/midi.clj')

diff --git a/src/unheard/midi.clj b/src/unheard/midi.clj
index 174fec2..b9f20c4 100644
--- a/src/unheard/midi.clj
+++ b/src/unheard/midi.clj
@@ -79,16 +79,17 @@
        (m/? (m/via m/blk (.setReceiver transmitter receiver)))
        (log/log! {:level :debug, :id :midi/receiver-set})
        (m/?
-        (t (m/ap
-            (loop []
-              (m/amb
-               (do
-                 (log/log! {:level :debug, :id :midi/tx-awaiting-value})
-                 (m/amb))
-               (let [v (m/? rv)]
-                 (log/log! {:level :debug, :id :midi/tx-received-value, :data {:value (str v)}})
-                 v)
-               (recur))))))
+        (t (m/stream
+            (m/ap
+              (loop []
+                (m/amb
+                 (do
+                   (log/log! {:level :debug, :id :midi/tx-awaiting-value})
+                   (m/amb))
+                 (let [v (m/? rv)]
+                   (log/log! {:level :debug, :id :midi/tx-received-value, :data {:value (str v)}})
+                   v)
+                 (recur)))))))
        (finally
          (log/log! {:level :info, :id :midi/closing-tx})
          (m/? (m/via m/blk (.close transmitter)))
@@ -206,5 +207,5 @@
 
   (into {}
         (map (fn [[group instance]]
-               {group (into {}  (map (fn [[id flow]] {id (flow f)}) instance))})
+               {group (into {} (map (fn [[id flow]] {id (flow f)}) instance))})
              config)))
-- 
cgit v1.2.3