Struct Subagents 

pub struct Subagents { /* private fields */ }

Owns the child sessions, shared capacity, and tool state for one agent runtime.

Implementations

impl Subagents

pub fn new( max_concurrency: usize, ) -> (Self, UnboundedReceiver<ScopedAgentUpdate>)

Creates an isolated runtime and its typed update stream.

The receiver carries model events as well as lifecycle changes. Keep it alive and drain it continuously for the lifetime of the runtime. Dropping it ends event forwarding and makes later lifecycle changes unobservable. A zero concurrency limit creates the runtime but rejects child turns until the limit is raised.

pub fn downgrade(&self) -> WeakSubagents

Returns a non-owning handle for tool factories and other runtime-owned callbacks.

pub fn set_agent_factory<F>( &self, thinking: Thinking, fast_mode: bool, factory: F, ) -> Result<(), NanocodexError>

where F: Fn(Model, Thinking, bool) -> Result<(Nanocodex, AgentEvents), NanocodexError> + Send + Sync + 'static,

Configures how clean child sessions are constructed.

The factory must return a new session and its event stream on every call. The runtime supplies the requested model and the current inherited settings. A runtime accepts exactly one factory; a second call returns NanocodexError::InvalidRequest.

Errors

Returns NanocodexError::InvalidRequest if a factory is already configured.

pub fn root_agent_authority(&self) -> RootAgentAuthority

Returns a root-session authority checker for application-owned tools.

pub fn set_max_concurrency(&self, limit: usize)

Changes the maximum number of concurrently active child turns.

Lowering the limit does not cancel active turns. New reservations fail until the active count falls below the new limit.

pub fn set_thinking(&self, thinking: Thinking)

Changes the reasoning effort inherited by newly created child sessions.

pub fn set_fast_mode(&self, enabled: bool)

Changes the fast-mode setting inherited by newly created child sessions.

pub async fn cancel_all(&self, root_session_id: &str)

Attempts to interrupt every active child without closing reusable sessions.

Shutdown is best effort and bounded. Individual child failures are reflected in updates.

pub async fn close_all(&self, root_session_id: &str)

Attempts to close and join every child owned by a root session.

Shutdown is best effort and bounded. Individual child failures are reflected in updates.

pub fn runtime_id(&self) -> SubagentRuntimeId

Returns the identity used to reject updates from a replaced runtime.

Trait Implementations

impl Clone for Subagents

fn clone(&self) -> Subagents

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.