Hi, does anybody know why async/to-chan doesn’t create a channel with 1 element buffer, but with min(100,collLength). Performance reasons?

(defn to-chan
  "Creates and returns a channel which contains the contents of coll,
  closing when exhausted."
  [coll]
  (let [ch (chan (bounded-count 100 coll))]
    (onto-chan ch coll)
    ch))

(defn process [n] (print n) n)
(def c (async/to-chan (map process (range 10)))) ;; Prints 0 - 9

@artemyarulin: to-chan is a convenience method for onto-chan, you can supply your own buffer to onto-chan that behaves as you wish

to-chan is implemented with onto-chan

Yeah, thx - I know it. I just wonder why the buffer is not 1 length by default

Probably just a performance thing so that it spools ahead of lazy evaluation

Ah ok, thx. I’ll use async/onto-chan then

@artemyarulin: generally putting side effects in lazy sequences is an anti pattern, but it looks like what you put up was just a demo?

Yeah, I know it. It was just for the purpose of showing that laziness got lost

Thought so

thx for telling in any case