Struct SubtaskRegistry 

pub struct SubtaskRegistry { /* private fields */ }

Registry of active subtask handles for a session.

This is used by the gateway to track all running subtasks and allow the agent to list, join, or cancel them.

Implementations

impl SubtaskRegistry

pub fn new() -> Self

Create a new empty registry.

pub fn register<T: Send + 'static>( &mut self, handle: &SubtaskHandle<T>, label: impl Into<String>, )

Register a subtask. Call this after spawning.

pub fn cancel(&mut self, thread_id: &ThreadId) -> bool

Cancel a subtask by thread ID (cooperative via CancellationToken).

pub fn cancel_all(&mut self)

Cancel all subtasks (cooperative via CancellationToken).

pub fn list(&self) -> Vec<(ThreadId, String)>

List active subtask thread IDs with labels.

pub fn remove(&mut self, thread_id: &ThreadId)

Remove a completed subtask from the registry.

pub fn count(&self) -> usize

Get the number of active subtasks.

Trait Implementations

impl Default for SubtaskRegistry

fn default() -> Self

Returns the “default value” for a type.