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


(def results (take-segments! out-chan))

(fact (into #{} (butlast results)) => (into #{} people))

(doseq [v-peer v-peers]
  (onyx.api/shutdown-peer v-peer))

  [_ event]
  {:onyx.core/params [(atom {})]})

(defmethod l-ext/inject-lifecycle-resources :names
  [_ _] {:core.async/chan name-chan})

(defmethod l-ext/inject-lifecycle-resources :ages
  [_ _] {:core.async/chan age-chan})

(defmethod l-ext/inject-lifecycle-resources :out
  [_ _] {:core.async/chan out-chan})

(def v-peers (onyx.api/start-peers 4 peer-group))

(onyx.api/submit-job
