Clojurians Log v2

@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.

I don't have a workaround, sorry

No worries!

How bad do you need this ? I have to choose between the quick fix and the right fix

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.

Also like this is open source, I would never expect a maintainer to go out of their way to unblock me

Though of course I would be immensely grateful for any effort you do make

I can make a gist for you to give more context if that would be helpful

as a library author I do benefit from users succeeding with the library

hahaha fair enough ❤️

Here is the namespace that I'm building right now: https://github.com/telekid/unheard/blob/time-object-example/src/unheard/time_object.clj

https://github.com/telekid/unheard/blob/3a2f9bf5469885e988b001ffd4d00b4d5f61afb7/src/unheard/time_object.clj#L116

Nvm, it's simple:

(defn merge-flows [& flows]
  (m/ap (m/?> (m/?> (count flows) (m/seed flows)))))

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!
   )

Oh, I think that's probably https://github.com/leonoel/missionary/issues/116.