Liking cljdoc? Tell your friends :D
app-sauce.async.pipeline
consume!clj
(consume! pipeline from to)(consume! pipeline from to pred)dispatchclj
(dispatch this worker msg)injectclj
(inject this worker msg)pipeclj
(pipe from-mult to-chan)(pipe from-mult to-chan pred)startclj
(start workers)stop!clj
(stop! pipeline)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close