Struct ChildSpawner 

pub struct ChildSpawner { /* private fields */ }

Spawner for managing children within a Runner.

Implementations

impl ChildSpawner

pub fn new(parent_id: impl Into<String>, output_tx: OutputSender) -> Self

Creates a new ChildSpawner.

Arguments

• parent_id - ID of the parent Component/Child
• output_tx - Sender for output events

pub fn with_max_children(self, max: usize) -> Self

Sets the maximum number of children.

pub fn child_count(&self) -> usize

Returns the number of active children.

pub fn max_children(&self) -> usize

Returns the maximum allowed children.

pub fn parent_id(&self) -> &str

Returns the parent ID.

pub fn spawn( &mut self, config: ChildConfig, child: Box<dyn RunnableChild>, ) -> Result<Box<dyn ChildHandle>, SpawnError>

Spawns a child and returns a handle.

Arguments

• config - Configuration for the child
• child - The RunnableChild instance

Errors

Returns error if:

• Max children reached
• Child with same ID already exists

pub fn spawn_async( &mut self, config: ChildConfig, child: Box<dyn RunnableChild>, ) -> Result<Box<dyn AsyncChildHandle>, SpawnError>

Spawns a child and returns an async handle.

Unlike Self::spawn(), this returns a handle that properly uses spawn_blocking for async execution.

Arguments

• config - Configuration for the child
• child - The RunnableChild instance

Errors

Returns error if:

• Max children reached
• Child with same ID already exists

pub fn propagate_signal(&mut self, signal: &Signal)

Propagates a signal to all children.

pub fn abort_all(&mut self)

Aborts all children.

pub fn reap_finished(&mut self) -> Vec<(String, Status)>

Removes finished children and returns their results.

pub fn child_ids(&self) -> Vec<String>

Returns the IDs of all active children.

pub fn output_tx(&self) -> &OutputSender

Returns the output sender.

pub fn get_child_arc( &self, id: &str, ) -> Option<Arc<Mutex<Box<dyn RunnableChild>>>>

Returns a clone of the child’s Arc for out-of-lock execution.

Used by send_to_children_batch to collect child references while briefly holding the spawner lock, then release it before running.

pub fn run_child(&self, id: &str, input: Value) -> Result<ChildResult, RunError>

Runs a child by ID with the given input.

Arguments

• id - The child ID
• input - Input data to pass to the child

Returns

The child’s result, or an error if:

• Child not found
• Child lock failed

Trait Implementations

impl Debug for ChildSpawner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.