Struct PipelineRun 

pub struct PipelineRun { /* private fields */ }

A pipeline running on its own OS thread, with its exit result delivered over a channel so tests can wait with a bounded recv_timeout instead of polling JoinHandle::is_finished.

Implementations

impl PipelineRun

pub fn spawn( run: impl FnOnce() -> Result<ExitReport, StartError> + Send + 'static, ) -> Self

Spawn run (typically move || runtime.run()) on a new thread; its result is sent over the channel when it returns.

pub fn wait_exit( &self, timeout: Duration, ) -> Option<Result<ExitReport, StartError>>

Block until the pipeline exits or timeout elapses; None on timeout.

Use this to wait for a pipeline that stops on its own (e.g. a Fail-policy fatal) without a manual shutdown trigger.

pub fn join(self) -> Result<ExitReport, StartError>

Block until the pipeline exits and join its thread, returning the run result. Panics if the thread panicked.

Trait Implementations

impl Debug for PipelineRun

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.