Batching buffer for Clojure's core.async