   (:require [clojure.core.async :refer [chan >!! <!! close! sliding-buffer]]
             [midje.sweet :refer :all]
             [onyx.plugin.core-async :refer [take-segments!]]
-            [onyx.test-helper :refer [load-config]]
+            [onyx.extensions :as extensions]
+            [onyx.test-helper :refer [load-config playback-log get-counts]]
             [onyx.api]))
 
 (def id (java.util.UUID/randomUUID))

(def batch-size 20)

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

(defn restartable? [e]


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

(fact @startup-counter => 2)

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