std.task.process

*interrupt*

dynamic

invoke

added in 4.0

(invoke task & args)

executes the task, given functions and parameters

main-function

added in 4.0

(main-function func count)

creates a main function to be used for execution (main-function ns-aliases 1) => (contains h/vargs? false)

select-filter

added in 4.0

(select-filter selector id)

matches given a range of filters

select-inputs

added in 4.0

(select-inputs task lookup env selector)

selects inputs based on matches

task-inputs

added in 4.0

(task-inputs task)(task-inputs task input)(task-inputs task input params)(task-inputs task input params env)(task-inputs task input params lookup env)

constructs inputs to the task given a set of parameters

wrap-execute

added in 3.0

(wrap-execute f task)

enables execution of task with transformations

((wrap-execute process-test-fn +task+) 1 {} {} {}) => 3

wrap-input

added in 3.0

(wrap-input f task)

enables execution of task with single or multiple inputs ((wrap-input process-test-fn +task+) 1 {} {} {}) => 2

(let [task (assoc-in +task+ :item :list(constantly 1 2 3)) f (wrap-execute process-test-fn task) res ((wrap-input f task) :all {} {} {})] (get res 2) => 3 (get res 3) => 5 (get res 4) => 7)