Struct SubSession 

pub struct SubSession { /* private fields */ }

Long-lived conversation session for a subagent.

Implementations

impl SubSession

pub fn close(self: Arc<Self>)

Closes the session.

This is a no-op today: the input channel closes on its own once every sender clone is dropped, and the runner exits at its next idle boundary. The method is kept as the single place to hook explicit teardown (e.g. cancelling the runner) if that becomes necessary.

pub fn stop_background_task(&self, task_id: &str) -> bool

Actively stops a single background task running inside this session.

Marks the task as stopped so its remaining progress/end output is no longer forwarded, then signals the task’s stop handle so the producer terminates it (a nested tool process is killed; a nested subagent session receives a graceful /stop). Returns true if a live task with task_id was found.

Trait Implementations

impl AgentHook for SubSession

fn on_background_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 AgentCtx, handle: BackgroundHandle, _req: &'life2 CompletionRequest, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when an agent starts in the background.

fn on_background_progress<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 AgentCtx, session_id: String, output: AgentOutput, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when an agent reports progress from a background task.

fn on_background_end<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 AgentCtx, session_id: String, output: AgentOutput, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called with the final output from a background agent task.

fn before_agent_run<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 AgentCtx, prompt: String, resources: Vec<Resource>, ) -> Pin<Box<dyn Future<Output = Result<(String, Vec<Resource>), BoxError>> + Send + 'async_trait>>

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

Called before an agent is executed, allowing you to modify the prompt and resources.

fn after_agent_run<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 AgentCtx, output: AgentOutput, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput, BoxError>> + Send + 'async_trait>>

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

Called after an agent is executed, allowing you to modify the output.

impl ToolBackgroundHook for SubSession

fn on_background_start<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 BaseCtx, handle: BackgroundHandle, _args: Json, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a tool starts a background task.

fn on_background_progress<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 BaseCtx, task_id: String, output: ToolOutput<Json>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a tool reports progress from a background task.

fn on_background_end<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 BaseCtx, task_id: String, output: ToolOutput<Json>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called with the final output from a background tool task.