pipeline.clj

(do
  (require '[immutant.pipeline :as pl])
  (defn return-nil [& _] nil)
  (defn return-something [& _] "something")
  (defonce nil-pipe (pl/pipeline "nilpipe" return-nil))
  (defonce something-pipe (pl/pipeline "somethingpipe" return-something))
  {:nil (deref (nil-pipe :an-arg) 2000 :nilpipe-timed-out)
  :something (deref (something-pipe :an-arg) 2000 :somethingpipe-timed-out)})
;; => {:nil :nilpipe-timed-out, :something "something"}