Struct EngineSink 

pub struct EngineSink { /* private fields */ }

Concrete OutputSink — the default implementation that closes over engine, token, task_id, and attempt, and calls engine.submit_output for every emit. Injected by the InProcSpawner into WorkerInvocation.

Implementations

impl EngineSink

pub fn new( engine: Engine, token: CapToken, task_id: TaskId, attempt: u32, ) -> Self

Binds a sink to one attempt’s identity so every emit call knows where to route the event without the caller repeating the coordinates each time.

Trait Implementations

impl Clone for EngineSink

fn clone(&self) -> EngineSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl OutputSink for EngineSink

fn emit<'life0, 'async_trait>( &'life0 self, event: OutputEvent, ) -> Pin<Box<dyn Future<Output = Result<(), EngineError>> + Send + 'async_trait>>

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

Emits one OutputEvent (progress, final, etc.) into the engine’s output stream for this attempt.