Skip to content

Instantly share code, notes, and snippets.

@tobias

tobias/pipeline-example.clj

Created August 26, 2013 15:52
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save tobias/6343016 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save tobias/6343016 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pipeline-example.clj
(require '[immutant.pipeline :as pl])
(defonce fanout-pl
(pl/pipeline :fanout-example
#(repeat % "hi")
(fn [xs]
(doseq [x xs]
(pl/*pipeline* x :step pl/*next-step*))
pl/halt)
(pl/step println :concurrency 5)))
(fanout-pl 5)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment