Liking cljdoc? Tell your friends :D

app-sauce.async.pipeline


consume!

(consume! pipeline from to)
(consume! pipeline from to pred)

dispatch

(dispatch this worker msg)

inject

(inject this worker msg)

pipe

(pipe from-mult to-chan)
(pipe from-mult to-chan pred)

start

(start workers)

stop!

(stop! pipeline)

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close