                      (if (empty? buffer)
                        ; We're stable; flush this event immediately.
                        (assoc state :out (list event))
-                       
+
                        ; We're buffering.
                        (let [buffer (conj buffer event)]
                          (if (<= dt (- (:time event) (:time (first buffer))))

    (.execute executor
             (bound-fn runner []
               (call-rescue event children)))))
    
(defn moving-event-window
  "A sliding window of the last few events. Every time an event arrives, calls
  children with a vector of the last n events, from oldest to newest. Ignores

    (notify-www-team)
    (else
      (notify-misc-team)))

  The streams generated by (where) return the value of expr: truthy if expr
  matched the given event, and falsey otherwise. This means (where (metric 5))
  tests events and returns true if their metric is five."
