Struct EchoExecutor 

pub struct EchoExecutor;

Dependency-free executor: streams one token event per word, then completes with an echo. Used by the demo worker and tests to exercise the full transport without a real LLM.

Test hook: an assignment starting with __sleep_ms:<n> sleeps (cancellably) for n milliseconds before echoing the rest — this is what lets cancel / concurrency e2e tests hold a run open deterministically without an LLM.

Trait Implementations

impl ChildExecutor for EchoExecutor

fn run<'life0, 'async_trait>( &'life0 self, spec: RunSpec, events: EventSink, _steer: SteerInbox, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = ChildOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,