 
 (def ages (map #(select-keys % [:id :age]) people))
 
-(def name-chan (chan (inc names)))
+(def name-chan (chan (inc (count names))))
 
-(def age-chan (chan (inc ages)))
+(def age-chan (chan (inc (count ages))))
 
-(def out-chan (chan (sliding-buffer (inc n-messages))))
+(def out-chan (chan 10000 #_(sliding-buffer (inc n-messages))))
 
 (doseq [name names]
   (>!! name-chan name))

            [onyx.peer.task-lifecycle-extensions :as l-ext]
            [onyx.plugin.core-async :refer [take-segments!]]
            [onyx.test-helper :refer [load-config]]
            [onyx.api]))

(def id (java.util.UUID/randomUUID))


(def env (onyx.api/start-env env-config))

(def peer-group (onyx.api/start-peer-group peer-config))
(def batch-size 2)

(def people
