Hanh Huynh Huu <hanh...@gmail.com> writes: > If I replace the buffer with a dropping buffer or a sliding buffer, it > works but I can't afford to drop messages. However, I'd be fine with a > larger buffer than 1024. I also replaced the >!! with >! and > async/put!, but the result is the same. > > Is there a way to achieve my goal?
The 1024 is defined as (def ^:const ^int MAX-QUEUE-SIZE 1024) in namespace clojure.core.async.impl.protocols. So you could do (in-ns 'clojure.core.async.impl.protocols) (def ^:const ^int MAX-QUEUE-SIZE 2048) (in-ns 'your.own.ns) to override it. However, I don't know if that's a good idea... Bye, Tassilo -- 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.
