I'm also wondering how this could be done. I have a similar use case On Tuesday, October 22, 2013 at 9:30:08 AM UTC+2, Alexander L. wrote: > > Sorry for bringing this back up, but I was wondering if anyone figured out > something better... > > On Saturday, September 14, 2013 10:49:08 PM UTC+3, Alexander L. wrote: >> >> >> 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/d/optout.
