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_interactive_approvals(self) -> Self

Enable inline approval prompts (interactive TUI only). The gate then pauses gated tools and routes the user’s decision through the ApprovalBroker instead of writing an out-of-band DB approval row.

pub fn with_interactive_questions(self) -> Self

Enable inline ask_user_question prompts (interactive TUI only). The tool then parks on the QuestionBroker and routes the user’s answers back through it instead of proceeding without asking.

pub fn spawn_config_watcher(&mut self, cwd: PathBuf, memory: MemoryConfig)

Start the background config watcher (#45): it polls MERMAID.md + memory and emits Msg::InstructionsChanged/MemoryChanged on change, so the reducer reads them as injected data instead of refreshing inline. Call once at startup. Live-loop only — a replay driver feeds the recorded Changed Msgs rather than polling.

pub fn with_task_id(self, task_id: Option<String>) -> Self

Attach a durable runtime task id so tool runs, approvals, checkpoints, compactions, and background processes can be linked.

pub fn without_terminal_title(self) -> Self

Disable terminal-title writes for non-interactive callers.

pub fn without_global_mcp_shutdown(self) -> Self

Leave the process-global MCP manager alone on shutdown. Child (subagent) runners share it with the parent and must not reap it.

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 pair_from_with_task( workdir: PathBuf, providers: Arc<ProviderFactory>, tools: Arc<ToolRegistry>, task_id: Option<String>, ) -> (Self, Receiver<Msg>)

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.