Trait AsyncChildContext

Source

pub trait AsyncChildContext:
    Send
    + Sync
    + Debug {
    // Required methods
    fn parent_id(&self) -> &str;
    fn emit_output(&self, message: &str);
    fn emit_output_with_level(&self, message: &str, level: &str);
    fn spawn_child<'life0, 'async_trait>(
        &'life0 self,
        config: ChildConfig,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AsyncChildHandle>, SpawnError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn child_count(&self) -> usize;
    fn max_children(&self) -> usize;
    fn send_to_child(
        &self,
        child_id: &str,
        input: Value,
    ) -> Result<ChildResult, RunError>;
    fn clone_box(&self) -> Box<dyn AsyncChildContext>;

    // Provided method
    fn send_to_child_async(
        &self,
        _child_id: &str,
        _input: Value,
    ) -> Result<(), RunError> { ... }
}

Expand description

Async context provided to Children for runtime interaction.

This trait provides async versions of ChildContext methods for children that need to spawn async children.

§Example

#[async_trait]
impl AsyncRunnableChild for MyWorker {
    async fn run(&mut self, input: Value) -> ChildResult {
        if let Some(ctx) = &self.async_ctx {
            ctx.emit_output("Starting async work...");

            // Spawn an async child
            let config = ChildConfig::from_inline("sub-1", "...");
            if let Ok(mut handle) = ctx.spawn_child(config).await {
                let result = handle.run(input.clone()).await;
                // ...
            }
        }
        ChildResult::Ok(input)
    }
}