On Jan 5, 2018, at 8:01 PM, Gary Verhaegen <gary.ve...@gmail.com> wrote:

> What about simply having the producer put items one by one on the channel?


I will do that. My current producer is doing too many other things, but if 
I break it up into separate threads or go blocks for each work queue, then 
that should work. Thank you.
 

On Saturday, January 6, 2018 at 8:22:34 AM UTC-5, Brian J. Rubinton wrote:
>
> I think the behavior in our examples differ because the blocking puts will 
> complete whenever there is a take and the buffer is not full, ignoring 
> whether the transducer is still outputting values. This bug may be 
> relevant, though there it arises in a less common scenario (fixed buffer of 
> size 0, which is now disallowed) 
> https://dev.clojure.org/jira/browse/ASYNC-140
>

So, should I report this as a bug? If you have channel with a buffer and a 
(mapcat identity) transducer, the number of items in the channel can grow 
without bound. I thought channels were supposed to prevent that.

 

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

Reply via email to