Struct SubagentOperation 

pub struct SubagentOperation<S> { /* private fields */ }

Implementations

impl<S> SubagentOperation<S>

pub fn new(runner: Arc<dyn SubagentRunner<S>>) -> Self

pub fn with_max_concurrency(self, max_concurrency: NonZeroUsize) -> Self

Limits how many subagents run at once; additional subagents remain pending.

Trait Implementations

impl<S, E> Operation<S, E> for SubagentOperation<S>

where S: MaybeSend + MaybeSync + 'static, E: From<Message> + MaybeSend + 'static,

fn name(&self) -> &'static str

fn finalize_cancellation<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session: &'life1 S, conversation: &'life2 Conversation, emit: &'life3 Emitter, ) -> Pin<Box<dyn Future<Output = Vec<E>> + Send + 'async_trait>>

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

fn run<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session: &'life1 S, conversation: &'life2 Conversation, emit: &'life3 Emitter, ) -> Pin<Box<dyn Future<Output = Result<OperationResult<E>>> + Send + 'async_trait>>

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

fn set_message_meta(&self, message: &mut Message, key: &str, value: Value)

Note on a message something this operation did, so that a pipeline rebuilt from the persisted conversation reaches the same conclusion. Notes record past actions only — anything an operation would have to compute again does not belong here.

fn message_meta<'a>(&self, message: &'a Message, key: &str) -> Option<&'a Value>

fn run_command<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, _command: &'life1 SlashCommand<'life2>, _session: &'life3 S, _conversation: &'life4 Conversation, _emit: &'life5 Emitter, ) -> Pin<Box<dyn Future<Output = Result<OperationResult<E>>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

fn inference_tools<'life0, 'life1, 'async_trait>( &'life0 self, _session: &'life1 S, ) -> Pin<Box<dyn Future<Output = Result<Vec<Tool>>> + Send + 'async_trait>>

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

fn prompt_parts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _session: &'life1 S, _conversation: &'life2 Conversation, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String)>>> + Send + 'async_trait>>

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

fn moim_parts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _session: &'life1 S, _conversation: &'life2 Conversation, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

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