Caravela.Flow.Steps.Parallel (Caravela v0.5.3)

Copy Markdown View Source

Invoke tasks_fn.(state) to build a list of zero-arity funs, run them all concurrently, and collect each one's return under the collect_as key in state.

Summary

Types

t()

Types

t()

@type t() :: %Caravela.Flow.Steps.Parallel{
  collect_as: atom(),
  tasks_fn: (map() -> [(-> any())]),
  timeout: non_neg_integer()
}