concurrently.core
Cancellablecljprotocol
cancelclj
(cancel job)Chainablecljprotocol
chainclj
(chain source xf)(chain source xf ex-handler)Create a new Chainable which have same type with 'source' and supplies all items from source applying xf on them.
Create a new Chainable which have same type with 'source' and supplies all items from source applying xf on them.
cleanup-in-backgroundclj
(cleanup-in-background ch)Slurp all data in a channel and abandon them silently.
Slurp all data in a channel and abandon them silently.
concurrent-jobclj
(concurrent-job channel)(concurrent-job channel id)concurrent-processclj
(concurrent-process parallel-count output-ch f input-ch)Create a concurrent process backed by core.async/pipeline.
f must be a function of two arguments. the first is a value retrieved a pipeline.
the second is a options-map supplied to concurrently function.
f should be CPU-bounded, should not run blocking actions in f
Create a concurrent process backed by core.async/pipeline. `f` must be a function of two arguments. the first is a value retrieved a pipeline. the second is a options-map supplied to `concurrently` function. `f` should be CPU-bounded, should not run blocking actions in `f`
concurrent-process-blockingclj
(concurrent-process-blocking parallel-count output-ch f input-ch)Create a concurrent process backed by core.async/pipeline-blocking.
f must be a function of two arguments. the first is a value retrieved a pipeline.
the second is a options-map supplied to concurrently function.
You should use this function if the f is a blocking function.
Create a concurrent process backed by core.async/pipeline-blocking. `f` must be a function of two arguments. the first is a value retrieved a pipeline. the second is a options-map supplied to `concurrently` function. You should use this function if the `f` is a blocking function.
ConcurrentJobclj
concurrentlyclj
(concurrently {:keys [input-ch] :as context} items-ch options)current-concurrent-countclj
data-end?clj
(data-end? boxed)get-resultsclj
(get-results ch
&
[{catch-fn :catch
finally-fn :finally
context-name :context-name
timeout-ms :timeout-ms
:or {context-name "none" timeout-ms 120000}}])Safely read all data from a channel and return a vector containing all read data. the items read from a channel must be databoxes. The result vector contains unboxed data of the read items. If an exception occurred while resolving read items, an exception will be thrown.
This function will throw an exception if :timeout-ms option value isn't :no-timeout and no data available from the 'ch' channel after the :timeout-ms. The :catch function will be called if a databox contains an exception, then returns a failure databox. The :finally function will be called always.
'ch' will be read fully even if this function returns early before reading all data from 'ch',
because a go-block is launched automatically for reading 'ch' fully.
So a pipeline backing the 'ch' never be stacked by never-read-data remained in a pipeline.
Safely read all data from a channel and return a vector containing all read data. the items read from a channel must be databoxes. The result vector contains unboxed data of the read items. If an exception occurred while resolving read items, an exception will be thrown. This function will throw an exception if :timeout-ms option value isn't :no-timeout and no data available from the 'ch' channel after the :timeout-ms. The :catch function will be called if a databox contains an exception, then returns a failure databox. The :finally function will be called always. 'ch' will be read fully even if this function returns early before reading all data from 'ch', because a go-block is launched automatically for reading 'ch' fully. So a pipeline backing the 'ch' never be stacked by never-read-data remained in a pipeline.
job-cancelled?clj
(job-cancelled? transaction-id)jobsclj
take-or-throw!cljmacro
(take-or-throw! result-ch timeout-ms & [context-name])cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close