     :onyx/doc "Reads segments from a core.async channel"}
 
    {:onyx/name :intermediate-1
-    :onyx/fn :onyx.peer.fault-tolerance/process-middle
+    :onyx/fn :onyx.peer.fault-tolerance/int-1
     :onyx/batch-timeout batch-timeout
     :onyx/type :function
     :onyx/batch-size batch-size}
 
    {:onyx/name :intermediate-2
-    :onyx/fn :onyx.peer.fault-tolerance/process-middle
+    :onyx/fn :onyx.peer.fault-tolerance/int-2
     :onyx/type :function
     :onyx/batch-timeout batch-timeout
     :onyx/batch-size batch-size}

                         (if v 
                           (recur (conj after-done v))
                           after-done)))]
      (fact after-done => #{}))

    (close! kill-ch)
    (<!! mess-with-peers-ch)
    (helper-env/remove-n-peers test-env 9))

  (finally 
    (component/stop test-env)))

                                          (:peer-config config))))
(def batch-size 5)

(defn int-1 [segment]
  (assoc segment :a 1))

(defn int-2 [segment]
  (assoc segment :b 1))

(def batch-timeout 500)

