concurrently.async — concurrently 0.2.3

channel? clj

(channel? ch)

Freezable clj protocol

freeze clj

(freeze target-mix)

Freeze the supplied mix object.

freezable-mix clj

(freezable-mix out & [{:keys [full-read?] :or {full-read? false}}])

Create a mix object which is able to stop accepting 'admix' call after freezed. This mix is freezable by calling 'freeze' on this mix object. After the freezing, following admix call throw an exception. If all channel admixed before freezing are closed, the channel this mix object contains must be closed.

pipe clj

(pipe from to)

(pipe from to {:keys [close? full-read?] :or {close? true full-read? true}})

Same with 'pipe' fn of core.async, but never stop reading if the next channel is closed.

pipeline-unorderd clj

(pipeline-unorderd n to xf from close? ex-handler type)