Liking cljdoc? Tell your friends :D
Clojure only.

hara.concurrent.pipe


pipe

(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 %)

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 %)
raw docstring

send

(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]

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]
raw docstring

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

× close