Struct TransactionTaskSpawner 

pub struct TransactionTaskSpawner { /* private fields */ }

Cloneable handle workers use to spawn owned tasks without holding JoinHandles.

Implementations

impl TransactionTaskSpawner

pub async fn spawn<F>( &self, class: TaskClass, future: F, ) -> Result<TaskId, SpawnReject>

where F: Future<Output = ()> + Send + 'static,

Register then spawn future under class.

Uses try_send so workers never block forever on a full mailbox while the supervisor is in abort_and_drain. On Busy/Rejected before accept, the boxed future is returned so the caller can drive cleanup inline. On SpawnReject::Orphaned, the future is gone from the caller — fail closed.

pub async fn spawn_boxed( &self, class: TaskClass, future: Pin<Box<dyn Future<Output = ()> + Send + 'static>>, ) -> Result<TaskId, SpawnReject>

Same as Self::spawn with an already-boxed future (Busy retry).

pub fn try_spawn_owned<F>( &self, class: TaskClass, future: F, ) -> Result<(), SpawnReject>

where F: Future<Output = ()> + Send + 'static,

Sync try-spawn for ToolRuntime::start (no await). On success the supervisor owns the future; TaskId reply may be dropped (caller does not need it).

pub async fn spawn_with_busy_retry<F, C>( &self, class: TaskClass, future: F, max_retries: u32, is_cancelled: C, ) -> Result<TaskId, SpawnReject>

where F: Future<Output = ()> + Send + 'static, C: FnMut() -> bool,

Prefer supervisor ownership: bounded Busy retries, then return the last reject.

Does not drive the future inline — caller decides fail-closed vs last-resort join.

Trait Implementations

impl Clone for TransactionTaskSpawner

fn clone(&self) -> TransactionTaskSpawner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionTaskSpawner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.