Method spawn_from_messages

core/src/agent_api/runtime.rs:222–248

(
        self,
        messages: Vec<Message>,
    )

    }

    pub(super) fn spawn_from_messages(
        self,
        messages: Vec<Message>,
    ) -> (mpsc::Receiver<AgentEvent>, JoinHandle<()>) {
        let Self {
            agent_loop,
            runtime_tx,
            session_id,
            cancel_token,
            worker_state,
            forwarder,
            lifecycle,
            rx,
        } = self;
        let handle = tokio::spawn(async move {
            let result = agent_loop
                .execute_from_messages(
                    messages,
                    Some(&session_id),
                    Some(runtime_tx),
                    Some(&cancel_token),
                )
                .await;
            worker_state.complete(result).await;
        });
        (rx, lifecycle.wrap(handle, forwarder))
    }
}