diff options
| author | Jake Zerrer <him@jakezerrer.com> | 2025-11-07 15:42:03 -0500 |
|---|---|---|
| committer | Jake Zerrer <him@jakezerrer.com> | 2025-11-07 15:51:27 -0500 |
| commit | 945eb221209a6c3c00b2f0fcbbc7e19b343ee9d9 (patch) | |
| tree | badb4423a670751101ac84b25c80eee32cc9151c /src/unheard/midi.clj | |
| parent | 6b25663be05e32a856dfa64dc9dbc92990ccbc56 (diff) | |
Add new instrument
Diffstat (limited to 'src/unheard/midi.clj')
| -rw-r--r-- | src/unheard/midi.clj | 23 |
1 files changed, 12 insertions, 11 deletions
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))) |