                                        (partial swap! res conj)))]
                     (dorun (map stream events))
                     (is (= expect @res))))
-         
+
          (testing "evaluates streams once"
                   (let [res (atom [])
-                        stream (split 
+                        stream (split
                                  true
                                  (let [state (atom 0)]
                                    (fn [_]


(deftest exception-stream-test
         (testing "direct fn"
                  (logging/suppress 
                    ["riemann.streams" "riemann.streams-test"]

                    (let [out        (atom [])

                         (fn [e] (dosync (alter output conj e))))
               metrics [0.5 1 1.5 2 2.5]
               expect [1 1.5 2]]

           (doseq [m metrics] (r {:metric m}))
           (is (= expect (vec (map (fn [s] (:metric s)) (deref output))))))))

