Struct ConsoleEval 

pub struct ConsoleEval { /* private fields */ }

Async bridge between the sync TUI and an rpc::Session eval worker.

Implementations

impl ConsoleEval

pub fn submit(&mut self, form: String) -> Option<u64>

Wraps form in a fresh (:id {next_id} :form {form}) envelope and hands it to the worker. Non-blocking. Returns Some(id) with the allocated envelope id on success, or None when the channel is closed (the worker has stopped).

pub fn drain(&mut self) -> Vec<DrainItem>

Drains every ready response without blocking. Each received wire frame is parsed to extract its :id and classified as DrainItem::Routed (positive id), DrainItem::Unroutable (id 0 / non-integer id / parse error), or DrainItem::Notice (worker-stopped plain-text, emitted at most once).

pub fn interrupt(&self)

Requests a cooperative cancel of the in-flight eval. Advances the interrupt generation first (caught by handle_form’s pre-start check_interrupt if the eval has not entered Wasm yet) then bumps the engine epoch (traps an eval already running) — the eval_channel ordering that closes the worker-pickup window.

pub fn spawn(handle: &Handle, user_id: Uuid) -> Result<Self, SessionError>

Builds a real Session for user_id and spawns its eval worker.

pub fn echo(handle: &Handle) -> Self

Spawns a runtime-only worker that echoes each received frame back verbatim. No Session, no DB; used to exercise the channel/drain plumbing in isolation.