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.

InProcSpawner::spawn is this type’s sole constructor, which is what makes it the in-process lane’s “the worker itself did this” boundary: an OutputEvent::Artifact arriving here is a part the worker staged, as opposed to one some other producer appended to the same shared tail (AfterRunAuditMiddleware calls submit_output directly for exactly that reason). emit therefore records Artifact names into EngineState.worker_artifact_names — the allowlist the Final-pull folds {out, parts} from. Adding a second constructor for a non-worker producer would break that invariant; such a producer should call Engine::submit_output directly instead.

Implementations

impl EngineSink

pub fn new( engine: Engine, token: CapToken, task_id: StepId, 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.