Struct EffectRunner 

pub struct EffectRunner { /* private fields */ }

The runner. One instance per process, constructed by app::run and consumed when the main loop exits.

Implementations

impl EffectRunner

pub fn new(msg_tx: MsgSender, workdir: PathBuf) -> Self

Create an unused runner. Pair with msg_rx from channel().

pub fn with_bindings( self, providers: Arc<ProviderFactory>, tools: Arc<ToolRegistry>, ) -> Self

Attach provider + tool registries. Production wiring uses this; unit tests that don’t need real dispatch can skip. Without bindings, CallModel / ExecuteTool emit well- formed error Msgs so the reducer still transitions cleanly.

pub fn pair(workdir: PathBuf) -> (Self, Receiver<Msg>)

Pair-constructor: returns both the runner and the receiving end of the Msg channel. Preferred for production wiring because it keeps the channel capacity constant in one place.

pub fn pair_with_bindings( workdir: PathBuf, config: Config, tools: Arc<ToolRegistry>, ) -> (Self, Receiver<Msg>)

Pair constructor that also wires the real provider factory + tool registry. Used by app::run_interactive.

pub fn pair_from( workdir: PathBuf, providers: Arc<ProviderFactory>, tools: Arc<ToolRegistry>, ) -> (Self, Receiver<Msg>)

Pair constructor that takes a pre-built ProviderFactory. Used when the caller needs to share a ProviderFactory with the SubagentSpawner so subagents can issue model calls through the same cache.

pub fn new_child( msg_tx: MsgSender, workdir: PathBuf, providers: Arc<ProviderFactory>, tools: Arc<ToolRegistry>, ) -> Self

Construct a runner that shares a pre-derived cancellation token for its turn scopes. Used by SubagentSpawner so the child runner’s work aborts as soon as the parent’s ctx.token fires.

pub fn scope_count(&self) -> usize

Number of active per-turn scopes. Tests use this to observe lifecycle without racing on internal state.

pub fn dispatch(&mut self, cmd: Cmd)

Route a single Cmd into the appropriate spawn + handler. Returns immediately; handlers work asynchronously and emit Msg back through the sender channel.

pub async fn shutdown(self)

Async shutdown: cancel every scope, then wait for all spawned work to drain. Bounded by 5 seconds — a hung task past that gets aborted outright by JoinSet::drop.