concurrently.core — concurrently 0.1.0

Cancellable clj protocol

cancel clj

(cancel job)

chain clj

(chain source-ch xf & [ex-handler])

Create a channel supplied a transducer.

cleanup-in-background clj

(cleanup-in-background ch)

Slurp all data in a channel and abandon them silently.

concat clj

(concat ch & chs)

Connect a channel to a tail of another channel.

concurrent-job clj

(concurrent-job channel)

(concurrent-job channel id)

concurrent-process-blocking clj

(concurrent-process-blocking parallel-count output-ch f input-ch)

concurrently clj

(concurrently {:keys [input-ch] :as context} items-ch options)

current-concurrent-count clj

data-end? clj

(data-end? boxed)

get-results clj

(get-results ch
             &
             [{catch-fn :catch
               finally-fn :finally
               context-name :context-name
               timeout-ms :timeout-ms
               :or {context-name "none" timeout-ms 120000}}])

job-cancelled? clj

(job-cancelled? transaction-id)

jobs clj

take-or-throw! clj macro

(take-or-throw! result-ch timeout-ms & [context-name])