                         (is (= (:state e)   "error"))
                         (is (= (:time e)    0))
                         (is (re-find #".*RuntimeException.*" (:description e)))
-                        (is (= #{"exception" "java.lang.RuntimeException"} 
+                        (is (= #{"exception" "java.lang.RuntimeException"}
                                (set (:tags e))))))))
 
          (testing "scheduled fn"
-                  (logging/suppress 
+                  (logging/suppress
                     "riemann.streams"
                     (reset-time!)
                     (let [e     (atom nil)

                                {:metric 2 :state :ok}]
                        stream (split* (sup 10) (with :state :critical
                                                      (partial swap! res conj))
                                       (sup 5) (with :state :warn 
                                                     (partial swap! res conj))
                                       (with :state :ok
                                             (partial swap! res conj)))]

         ; Do nothing the first time
         (test-stream (ddt) [{:metric 1 :time 0}] [])
         ; Differentiate
         (test-stream (ddt)
                      [{:metric 0 :time 0}
                       {:metric 0 :time 1}
                       {:metric 2 :time 2}
