Struct InterpreterTask 

pub struct InterpreterTask<'a> { /* private fields */ }

Drives one interpreter task on the scheduler.

Implementations

impl<'a> InterpreterTask<'a>

pub fn new( fut: Pin<Box<dyn Future<Output = Result<(), String>> + 'a>>, ys: Yield<'a>, err_sink: Option<ErrSink>, ) -> Self

Wrap a suspended interpreter future + its side-channel. err_sink, when set, receives the task’s error if it fails (first error wins).

Trait Implementations

impl<'a> Task<'a> for InterpreterTask<'a>

fn poll(&mut self, ctx: &mut TaskCtx) -> TaskStep<'a>

Advance the task until its next scheduling point.

fn priority(&self) -> u8

Scheduling priority — higher runs first under [crate::SchedulePolicy::Priority]. Defaults to 0 (all tasks equal).

fn take_output(&mut self) -> Vec<String>

Output lines the task produced during the just-finished poll slice, in order. The work-stealing driver collects these per slice and flushes them in the deterministic pick-order apply, so concurrent output matches the cooperative interleaving byte-for-byte. Cooperative tasks write straight to their sink and leave this empty (the default).