Skip to content

Commit

Permalink
Fix wrapping of proc-fns for latency measurement.
Browse files Browse the repository at this point in the history
  • Loading branch information
ruedigergad committed May 20, 2016
1 parent 8659695 commit 0b81a70
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/dsbdp/main.clj
Expand Up @@ -175,7 +175,7 @@
(if (and (vector? fns) (:latency options))
(do
(println "Wrapping proc-fns for latency measurement.")
(vec (map (fn [f] (fn [^LatencyProbe lp out] (f (.getData lp) out)) fns))))
(vec (map (fn [f] (fn [^LatencyProbe lp out] (f (.getData lp) out))) fns)))
(do
(println "Using fns vector as-is for proc-fns.")
fns)))))
Expand Down

0 comments on commit 0b81a70

Please sign in to comment.