Struct FanOutTask 

pub struct FanOutTask { /* private fields */ }

Composite task that executes multiple child tasks concurrently and aggregates results.

Implementations

impl FanOutTask

pub fn new(id: impl Into<String>, children: Vec<Arc<dyn Task>>) -> Arc<Self>

Create a new FanOutTask with an explicit id and a list of child tasks.

pub fn with_prefix(self: Arc<Self>, prefix: impl Into<String>) -> Arc<Self>

Set a context prefix for storing aggregated child results.

Aggregation keys will be written as <prefix>.<child_id>.<field>.

pub fn with_next_action(self: Arc<Self>, next: NextAction) -> Arc<Self>

Override the NextAction returned by the FanOutTask (default: Continue).

Trait Implementations

impl Clone for FanOutTask

fn clone(&self) -> FanOutTask

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Task for FanOutTask

fn id(&self) -> &str

Unique identifier for this task.

fn run<'life0, 'async_trait>( &'life0 self, context: Context, ) -> Pin<Box<dyn Future<Output = Result<TaskResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the task with the given context.