hara.concurrent.pipe — zcaudate/hara.concurrent.pipe 2.8.6

pipe clj

(pipe handler)

creates a pipe so that tasks can be acted upon asynchronously in order in which they were sent

(pipe (fn [msg] (println msg))) => #(instance? hara.concurrent.pipe.Pipe %)

send clj

(send pipe task)

sends a task to the pipe for it's handler to act upon

(def atm (atom []))

(def p (pipe (fn [msg] (swap! atm conj msg))))

(do (pipe/send p 1) (pipe/send p 2) (pipe/send p 3) (Thread/sleep 100) @atm) => [1 2 3]