keechma.pipelines.core — keechma/pipelines 0.1.0

begin-forms clj

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

cancel cljs

cancel-all cljs

cancel-on-shutdown cljs

(cancel-on-shutdown pipeline)

(cancel-on-shutdown pipeline should-cancel)

Should the pipeline be cancelled when the runtime is shut down

detached cljs

(detached pipeline)

(detached pipeline is-detached)

dropping cljs

(dropping pipeline)

(dropping pipeline max-concurrency)

Drop new request while another one is running

enqueued cljs

(enqueued pipeline)

(enqueued pipeline max-concurrency)

Enqueue requests and execute them sequentially

expand-body clj

(expand-body args body)

finally? clj

(finally? val)

get-active cljs

get-args cljs

get-ident cljs

has-pipeline? cljs

in-pipeline? cljs

invoke cljs

keep-latest cljs

(keep-latest pipeline)

(keep-latest pipeline max-concurrency)

Drop all intermediate requests, enqueue the last one

make-pipeline clj/s≠

clj

(make-pipeline _ _)

cljs

muted cljs

(muted pipeline)

pipeline! clj/s macro

(pipeline! args & body)

prepare-pipeline clj

(prepare-pipeline args body)

rescue-finally-forms clj

(rescue-finally-forms acc block args body)

rescue? clj

(rescue? val)

reset! cljs

(reset! & args)

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

restartable cljs

(restartable pipeline)

(restartable pipeline max-concurrency)

Cancel any running pipelines and start a new one

set-queue cljs

(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

start! cljs

stop! cljs

swap! cljs

(swap! & args)

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

use-existing cljs

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