gistfile1.txt

(defn mock-sink []
  (let [call-count (atom 0)
        call-args (atom "no args yet")]
    (with-meta (fn [_]
                 (fn [event]
                   (swap! call-count inc)
                   (reset! call-args event)))
      {:call-count call-count
       :call-args call-args})))

(defn call-count [mock]
  @(:call-count (meta mock)))

(fact "a hammered sink should not throw"
  (with-redefs [riemann.graphite/graphite (mock-sink)]
    (let [sink (init-internal {:host "fake"})
          events 120000
          _ (last (map deref (map (fn [_] (future (sink ..event..))) (range events))))]
      (call-count riemann.graphite/graphite) => events)))

;; fails with
FAIL "about the performance of graphite sinks - a hammered sink should not throw" at (graphite_test.clj:65)
    Expected: 120000
      Actual: 119997
FAILURE: 1 check failed.  (But 31 succeeded.)
Subprocess failed