moving-time-window retains state across tests

gistfile1.clj

(streams
 (moving-time-window 10
                     (tap :mtw
                          #(info %))))
(tests
 (let [input {:service "some-service"}]
   (deftest moving-time-window-should-not-retain-state-between-tests
     (is (= (inject! [input])
            {:mtw [[input]]})))

   (deftest moving-time-window-should-accumulate-events
     (is (= (inject! [input])
            {:mtw [[input]]})))))

16:50:51 powerhaus riemann-0.2.6 $ bin/riemann test etc/moving-time-window-should-not-retain-state.config 
loading bin

Testing riemann.config-test
INFO [2014-08-05 16:53:08,410] main - riemann.config - nil
INFO [2014-08-05 16:53:08,418] main - riemann.config - nil

FAIL in (moving-time-window-should-accumulate-events) (moving-time-window-should-not-retain-state.config:10)
expected: (= (inject! [input]) {:mtw [[input]]})
  actual: (not (= {:mtw [[{:service "some-service"} {:service "some-service"}]]} {:mtw [[{:service "some-service"}]]}))

Ran 2 tests containing 2 assertions.
1 failures, 0 errors.