Clojurians Log v2
Clojure programming
Channels
Apps
missionary 2025-11-14
telekid 2025-11-14T19:38:45.436899Z
I'm scratching my head trying to figure out a version of https://clojurians.slack.com/archives/CL85MBPEF/p1711763822414789?thread_ts=1711754747.466749&cid=CL85MBPEF that works when you want to merge a list of flows. (I guess I could probably solve it in my particular case with a macro, but I'd rather not.)
telekid 2025-11-17T16:03:15.405999Z
@leonoel do you think there is a way to work around this? My goal would be to capture the final value from each child branch.
leonoel 2025-11-17T16:42:55.187419Z
I don't have a workaround, sorry
telekid 2025-11-17T16:44:35.996799Z
No worries!
leonoel 2025-11-17T16:44:36.452949Z
How bad do you need this ? I have to choose between the quick fix and the right fix
telekid 2025-11-17T16:46:29.601529Z
Hm, medium-bad I think? It is blocking a key branch of work on a project that I'm spending most of my time on currently, but I can shift tasks to something else, or maybe I can come up with a different way to frame my solution.
telekid 2025-11-17T16:47:01.467019Z
Also like this is open source, I would never expect a maintainer to go out of their way to unblock me
telekid 2025-11-17T16:47:35.453989Z
Though of course I would be immensely grateful for any effort you do make
telekid 2025-11-17T16:48:36.258249Z
I can make a gist for you to give more context if that would be helpful
leonoel 2025-11-17T16:53:04.128389Z
as a library author I do benefit from users succeeding with the library
telekid 2025-11-17T16:55:04.877109Z
hahaha fair enough ❤️
telekid 2025-11-17T17:15:27.477509Z
Here is the namespace that I'm building right now: https://github.com/telekid/unheard/blob/time-object-example/src/unheard/time_object.clj
telekid 2025-11-14T19:49:56.038079Z
Nvm, it's simple:
(defn merge-flows [& flows]
(m/ap (m/?> (m/?> (count flows) (m/seed flows)))))telekid 2025-11-14T21:12:55.780589Z
Whoa, is this expected?
(defn with-final
[]
(m/ap
(m/amb=
:start
(try
(m/? m/never)
(catch missionary.Cancelled _ :end)))))
(defn merge-flows [& flows]
(m/ap
(m/?<
(m/?> (count flows) (m/seed flows)))))
(comment
(def cancel
((m/reduce prn nil (merge-flows (with-final)
(with-final))) prn prn))
(cancel) ;; prints end once
(cancel) ;; prints end again!
)telekid 2025-11-15T18:32:04.561279Z
Oh, I think that's probably https://github.com/leonoel/missionary/issues/116.