diff options
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))) |