Struct PipelineTask 

pub struct PipelineTask { /* private fields */ }

One running pipeline’s lifecycle handle.

Implementations

impl PipelineTask

pub fn new( pipeline: Pipeline, params: PipelineTaskParams, observers: Vec<Arc<dyn FrameObserver>>, ) -> Self

Build a task over pipeline with params and external observers.

pub async fn queue_frame(&self, frame: Frame)

Queue a downstream frame into the head of the pipeline.

pub async fn queue_frames(&self, frames: impl IntoIterator<Item = Frame>)

Queue several downstream frames.

pub fn queue_sender(&self) -> UnboundedSender<Frame>

A clonable handle to the head-injection queue, for an external producer (e.g. the S2S transport pump) that feeds frames into the pipeline head from its own task while run drives the pipeline. Sending after the task finished is a harmless no-op (the receiver is drained on shutdown).

pub async fn stop_when_done(&self)

Graceful: queue an End so the pipeline drains then shuts down.

pub async fn cancel(&self, reason: Option<String>)

Immediate: queue a Cancel.

pub fn has_finished(&self) -> bool

Whether the task has finished.

pub fn cancel_token(&self) -> CancellationToken

The shared cancellation token (a PipelineRunner holds it to force-abort on signal).

pub fn on_started(&mut self, f: impl Fn() + Send + Sync + 'static)

pub fn on_finished(&mut self, f: impl Fn(StopReason) + Send + Sync + 'static)

pub fn on_error(&mut self, f: impl Fn(&str, bool) + Send + Sync + 'static)

pub fn on_idle_timeout(&mut self, f: impl Fn() + Send + Sync + 'static)

pub async fn run(self) -> Result<()>

Run to completion (PROCESSOR-DESIGN §4.1): spawn all processor tasks, inject Start, wait until it reaches the Sink (ready), pump queued frames, and exit when a terminal frame reaches the Sink (or the cancel token fires).