Struct InProcSpawner 

pub struct InProcSpawner<W = MiddlewareWorker> {
    pub registry: HashMap<String, WorkerFn>,
    /* private fields */
}

agent-string → WorkerFn registry. The generic parameter W pins the per-kind Worker concrete type at the type level, so AgentBlock / Lua / RustFn each produce their own Worker type through InProcSpawner<W> and the type binding is preserved right up until SpawnerAdapter::spawn() erases the return as Box<dyn Worker>. W must be constructible from WorkerJoinHandler via From — i.e. a newtype that embeds the async-signal handle.

Fields

registry: HashMap<String, WorkerFn>

Agent name → implementation lookup table.

Implementations

impl InProcSpawner

pub fn new() -> Self

Creates an empty registry, defaulting the Worker type to MiddlewareWorker (used by existing call sites and tests).

pub fn register<F, Fut>(&mut self, agent: impl Into<String>, f: F) -> &mut Self

where F: Fn(WorkerInvocation) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkerResult, WorkerError>> + Send + 'static,

Registers a WorkerFn-shaped async closure under agent, overwriting any previous registration for the same name. Returns &mut Self for chained registration calls.

impl<W> InProcSpawner<W>

where W: Worker + From<WorkerJoinHandler> + Send + Sync + 'static,

pub fn typed() -> Self

Creates an empty registry pinned to Worker type W (the factory.build path uses this to get a per-kind Worker out of spawn() instead of the default MiddlewareWorker).

Trait Implementations

impl Default for InProcSpawner

fn default() -> Self

Returns the “default value” for a type.

impl<W: Worker + From<WorkerJoinHandler> + Send + Sync + 'static> SpawnerAdapter for InProcSpawner<W>

fn spawn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, engine: &'life1 Engine, ctx: &'life2 Ctx, task_id: TaskId, attempt: u32, token: CapToken, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Worker>, SpawnError>> + Send + 'async_trait>>

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

Spawn one attempt as a worker. Returns Box<dyn Worker>.