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/groups/opt_out.
