aion_flow - v0.5.0

aion/workflow/concurrency

Typed workflow concurrency combinators over homogeneous activity lists.

Values

all

</> 
pub fn all(
  activities: List(activity.Activity(i, o)),
) -> Result(List(o), error.ActivityError)

Spawn all activities concurrently and collect their typed outputs in input order.

Activity inputs are encoded with each activity’s input Codec; returned payloads are decoded one-by-one with the homogeneous output Codec. AT owns selective receive, fail-fast behaviour, correlation, and cancellation of remaining activities when any activity fails.

The collect is a yield point: pending workflow queries are serviced by the query pump before the fan-out settles, exactly as activity awaits, signal receives, timers, and child awaits do.

all_with_default

</> 
pub fn all_with_default(
  activities: List(activity.Activity(i, o)),
  workflow_default_task_queue: option.Option(String),
) -> Result(List(o), error.ActivityError)

all, supplying the workflow-level default task queue used for any member that selects none. Precedence (member override > workflow default > the named "default" queue) is resolved once at the engine schedule seam.

map

</> 
pub fn map(
  items: List(a),
  to_activity: fn(a) -> activity.Activity(i, o),
) -> Result(List(o), error.ActivityError)

Dynamically produce one activity per input element, then collect like all.

The v1 concurrency surface intentionally covers homogeneous-output list fan-out. Typed tuple variants such as all2/all3 are deferred additions.

map_with_default

</> 
pub fn map_with_default(
  items: List(a),
  to_activity: fn(a) -> activity.Activity(i, o),
  workflow_default_task_queue: option.Option(String),
) -> Result(List(o), error.ActivityError)

map, supplying the workflow-level default task queue used for any produced activity that selects none. Precedence (activity override > workflow default

the named "default" queue) is resolved once at the engine schedule seam.

race

</> 
pub fn race(
  activities: List(activity.Activity(i, o)),
) -> Result(o, error.ActivityError)

Race activities and return the first settled typed result.

This is FIRST SETTLE semantics, not first-success-wins: the first activity to finish wins whether it completes successfully or returns an ActivityError. AT records that winner and cancels the losers.

Like all, the race is a query-pump yield point: pending workflow queries are serviced while the race is parked.

race_with_default

</> 
pub fn race_with_default(
  activities: List(activity.Activity(i, o)),
  workflow_default_task_queue: option.Option(String),
) -> Result(o, error.ActivityError)

race, supplying the workflow-level default task queue used for any member that selects none. Precedence (member override > workflow default > the named "default" queue) is resolved once at the engine schedule seam.

✨ Search Document