Working on this gist: https://gist.github.com/telekid/c15ef0fe8fd8d47f36c3655d9e143f4b#file-debug-clj-L32

This program should play a very basic song, as described in https://gist.github.com/telekid/c15ef0fe8fd8d47f36c3655d9e143f4b#file-debug-clj-L35-L43

when working-version is set to true, the program works as expected

that is, the following is printed at the repl:

:c4 :start
:c4 :stop ;; three seconds later
:c5 :start ;; one second later
:c5 :stop ;; one second later
nil
user> 

however, when false, the program hangs at the following point:

:c4 :start

as far as I can tell, this is happening because my after function isn't liking something about the flow returned by m/watch

but it isn't obvious to me what would differ from the flow returned by m/watch vs the flow returned by m/ap

the flow returned by watch is continuous while the flow returned by ap is discrete, but I don't think that matters in this context

(after end) never terminates because end is Infinite

I think you want to terminate after first successful sleep, you can do that in the m/reduce stage Replace {} with (comp reduced {})

aaah, I thought I might need a reduced somewhere but I couldn't quite figure out where

thank you!

that fixed it