On Friday, January 5, 2018 at 2:03:00 PM UTC-5, Brian J. Rubinton wrote: > > > What is the buffered channel’s buffer used for? If that’s set to 1 and the > channel’s transducer is `(mapcat identity)` then the producer should be > able to continuously put chunks of work onto the channel with the puts only > completing when the previous chunk is completely consumed. >
The buffer is sort of a work queue, used to break up and distribute one "chunk" to a pool of consumers. I was imaging the buffer would be size 50. So the producer would grab 50 rows (one "chunk") and put them all in the channel. Consumers would pick them out one by one. I'm not familiar with the transducer concept so I need to go read a bit before I can understand your point about the channel's transducer being `(mapcat identity)`. -- 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.
