dbriones

(streams
 (throttle 1 10
           (tap :throttle
                #(info %))))
(tests
 (let [input {:service "some-service"}]
   (deftest throttle-should-allow-events-after-window-passes
     (is (= (inject! [input])
            {:throttle [input]}))

dbriones

(streams
 prn
 (where (service "digital")
        (with :service "analog" reinject)))

(tests
 (deftest reinject-test
   (inject! [{:service "digital"}])))