I am developing an application and I use core.async to push data from multiple threads within an infinite
(go (while true > (let [data (<! @my-channel) > (do processing here...))) in order to be processed. As you probably already figured out, I store my channel inside an atom defined at the start of my app. If an exception occurs in one of the threads, then I am calling a global exception handler which will reset the atom that holds the channel in order to flush it and make sure the processing of the data it contains will stop. Now, my question is, does anyone know a better way to flush a core.async channel or the only way is to re-create the channel? Thank you for your time. Regards, Alexander -- -- You received this message because you are subscribed to the Google Groups "Clojure" group. To post to this group, send email to clojure@googlegroups.com Note that posts from new members are moderated - please be patient with your first post. To unsubscribe from this group, send email to clojure+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/clojure?hl=en --- You received this message because you are subscribed to the Google Groups "Clojure" group. To unsubscribe from this group and stop receiving emails from it, send an email to clojure+unsubscr...@googlegroups.com. For more options, visit https://groups.google.com/groups/opt_out.
