 (doseq [n (range n-messages)]
   (>!! in-chan {:n n}))
 
-(>!! in-chan :done)
-(close! in-chan)
-
-(def v-peers (onyx.api/start-peers 4 peer-group))
+(def v-peers (onyx.api/start-peers 3 peer-group))
 
 (onyx.api/submit-job
  peer-config


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

(fact @startup-counter => 3)

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

(def batch-size 20)

(defn my-inc [{:keys [n] :as segment}]
  (assoc segment :n (inc n)))

(defn restartable? [e]
