 
 (close! colors-in-chan)
 
-(doseq [v-peer v-peers]
-  (onyx.api/shutdown-peer v-peer))
-
-(onyx.api/shutdown-peer-group peer-group)
-
-(onyx.api/shutdown-env env)
-
+(do
+  (doseq [v-peer v-peers]
+    (onyx.api/shutdown-peer v-peer))
+
+  (onyx.api/shutdown-peer-group peer-group)
+
+  (onyx.api/shutdown-env env))
+


(def green-out-chan (chan (sliding-buffer 100)))

(doseq [x [{:color "red" :extra-key "Some extra context for the predicates"}
           {:color "blue" :extra-key "Some extra context for the predicates"}
           {:color "white" :extra-key "Some extra context for the predicates"}
           {:color "green" :extra-key "Some extra context for the predicates"}
           {:color "orange" :extra-key "Some extra context for the predicates"}
           {:color "black" :extra-key "Some extra context for the predicates"}
           {:color "purple" :extra-key "Some extra context for the predicates"}
           {:color "cyan" :extra-key "Some extra context for the predicates"}
           {:color "yellow" :extra-key "Some extra context for the predicates"}]]
  (>!! colors-in-chan x))

(>!! colors-in-chan :done)

    :flow/exclude-keys [:extra-key]
    :flow/predicate :onyx.peer.colors-flow-test/orange?}

   #_{:flow/from :colors-in
    :flow/to [:process-blue]
    :flow/exclude-keys [:extra-key]
    :flow/predicate :onyx.peer.colors-flow-test/orange?}
