Is anyone able to explain the following behaviour?

Give the code:

(def results (chan 3))
(def repeater (mapcat> #(vec (take 3 (repeat %))) results 3))
;(close! rep-test-chan)
(go-loop []
  (prn (<! (partition 3 results)))
  (recur))

(put! repeater :something)

I'd expect an output of

[:something :something :something]

to be printed for every execution of

(put! repeater :something)

However, it only seems to print the expected output every other execution.

Note that 'partition is core.async/partition.

If anyone could verify this behaviour it'd be appreciated.
Thanks.

-- 
Note that posts from new members are moderated - please be patient with your 
first post.
--- 
You received this message because you are subscribed to the Google Groups 
"ClojureScript" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/clojurescript.

Reply via email to