Methods for managing promises from pending activities from within workflows
Methods for managing promises from pending activities from within workflows
(all coll)
Returns Promise that becomes completed when all arguments are completed.
N.B. A single promise failure causes resulting promise to deliver the failure immediately.
Similar to promesa/all but designed to work with
promises returned from temporal.activity/invoke
from within workflow context.
(-> (all [(a/invoke activity-a ..) (a/invoke activity-b ..)])
(promesa.core/then (fn [[a-result b-result]] ...)))
Returns Promise that becomes completed when all arguments are completed. *N.B. A single promise failure causes resulting promise to deliver the failure immediately.* Similar to [promesa/all](https://funcool.github.io/promesa/latest/promesa.core.html#var-all) but designed to work with promises returned from [[temporal.activity/invoke]] from within workflow context. ```clojure (-> (all [(a/invoke activity-a ..) (a/invoke activity-b ..)]) (promesa.core/then (fn [[a-result b-result]] ...))) ```
(race coll)
Returns Promise that becomes completed when any of the arguments are completed.
N.B. A single promise failure causes resulting promise to deliver the failure immediately.
Similar to promesa/race but designed to work with
promises returned from temporal.activity/invoke
from within workflow context.
(-> (race [(a/invoke activity-a ..) (a/invoke activity-b ..)])
(promesa.core/then (fn [fastest-result] ...)))
Returns Promise that becomes completed when any of the arguments are completed. *N.B. A single promise failure causes resulting promise to deliver the failure immediately.* Similar to [promesa/race](https://funcool.github.io/promesa/latest/promesa.core.html#var-race) but designed to work with promises returned from [[temporal.activity/invoke]] from within workflow context. ```clojure (-> (race [(a/invoke activity-a ..) (a/invoke activity-b ..)]) (promesa.core/then (fn [fastest-result] ...))) ```
(rejected e)
Returns a new, rejected promise
Returns a new, rejected promise
(resolved value)
Returns a new, fully resolved promise
Returns a new, fully resolved promise
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close