                expect [2 2.5]]
            
            (doseq [m metrics] (r {:metric m}))
-           (is (= expect (vec (map (fn [s] (:metric s)) (deref output)))))))
+           (is (= expect (vec (map (fn [s] (:metric s)) (deref output))))))))
 
 (deftest under-test
+(logging/suppress ["riemann.streams"]
          (let [output (ref [])
                r (under 1.5
                          (fn [e] (dosync (alter output conj e))))

           (doseq [event events]
             (s event))
           (is (= 6 (deref i)))))
(deftest within-test
         (let [output (ref [])
               r (within [1 2]
                         (fn [e] (dosync (alter output conj e))))

           (em 12 200)))

(deftest changed-test
  (let [states (partial map (partial hash-map :state))]
    (test-stream (changed :state)
                 (states [:ok :bad :bad :ok :ok :ok :evil :bad])
                 (states [:ok :bad :ok :evil :bad]))

    (test-stream (changed :state {:init :ok})
                 (states [:ok :bad :bad :ok :ok :evil :bad])
                 (states [:bad :ok :evil :bad]))))

(deftest changed-with-previous-test
         (let [output (atom [])
