Liking cljdoc? Tell your friends :D

keechma.pipelines.core


begin-formsclj

(begin-forms acc args {:keys [begin]})
source

cancelcljs

source

cancel-allcljs

source

cancel-on-shutdowncljs

(cancel-on-shutdown pipeline)
(cancel-on-shutdown pipeline should-cancel)

Should the pipeline be cancelled when the runtime is shut down

Should the pipeline be cancelled when the runtime is shut down
sourceraw docstring

detachedcljs

(detached pipeline)
(detached pipeline is-detached)
source

droppingcljs

(dropping pipeline)
(dropping pipeline max-concurrency)

Drop new request while another one is running

Drop new request while another one is running
sourceraw docstring

enqueuedcljs

(enqueued pipeline)
(enqueued pipeline max-concurrency)

Enqueue requests and execute them sequentially

Enqueue requests and execute them sequentially
sourceraw docstring

expand-bodyclj

(expand-body args body)
source

finally?clj

(finally? val)
source

get-activecljs

source

get-argscljs

source

get-identcljs

source

has-pipeline?cljs

source

in-pipeline?cljs

source

invokecljs

source

keep-latestcljs

(keep-latest pipeline)
(keep-latest pipeline max-concurrency)

Drop all intermediate requests, enqueue the last one

Drop all intermediate requests, enqueue the last one
sourceraw docstring

make-pipelineclj/s≠

clj
(make-pipeline _ _)
cljs
source (clj)source (cljs)

mutedcljs

(muted pipeline)
source

pipeline!clj/smacro

(pipeline! args & body)
source

prepare-pipelineclj

(prepare-pipeline args body)
source

rescue-finally-formsclj

(rescue-finally-forms acc block args body)
source

rescue?clj

(rescue? val)
source

reset!cljs

(reset! & args)

reset! that can be used inside pipeline! - returns nil so it doesn't change the current value

reset! that can be used inside pipeline! - returns nil so it doesn't change the current value
sourceraw docstring

restartablecljs

(restartable pipeline)
(restartable pipeline max-concurrency)

Cancel any running pipelines and start a new one

Cancel any running pipelines and start a new one
sourceraw docstring

set-queuecljs

(set-queue pipeline queue)

Explicitly set the queue name. Second argument can be a function in which case, it will be called with the pipeline arguments and should return a queue name

Explicitly set the queue name. Second argument can be a function in which case, it will be called with the pipeline arguments and should return a queue name
sourceraw docstring

start!cljs

source

stop!cljs

source

swap!cljs

(swap! & args)

swap! that can be used inside pipeline! - returns nil so it doesn't change the current value

swap! that can be used inside pipeline! - returns nil so it doesn't change the current value
sourceraw docstring

use-existingcljs

(use-existing pipeline)

If there is an in flight pipeline started with the same arguments, return its promise instead of starting a new one. It can be combined with any other concurrency behavior (restartable, dropping, enqueued and keep-latest)

If there is an in flight pipeline started with the same arguments, return its promise instead of starting a new one. It can be combined with any other concurrency behavior (`restartable`, `dropping`, `enqueued` and `keep-latest`)
sourceraw docstring

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

× close