Struct BoundedPipeline 

pub struct BoundedPipeline<T> { /* private fields */ }

Bounded FIFO pipeline with tracing.

Implementations

impl<T> BoundedPipeline<T>

pub fn new(config: PipelineConfig) -> Self

Creates an empty pipeline.

pub fn push(&mut self, stage: PipelineStage, value: T) -> RuntimeResult<()>

Enqueues a message or rejects when at capacity.

pub fn pop(&mut self) -> Option<(PipelineStage, T)>

Pops the next message.

pub fn trace(&self) -> &TraceLog

Returns the trace log.

pub fn len(&self) -> usize

Returns in-flight count.

pub fn is_empty(&self) -> bool

Returns whether the pipeline is empty.

Trait Implementations

impl<T: Clone> Clone for BoundedPipeline<T>

fn clone(&self) -> BoundedPipeline<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for BoundedPipeline<T>

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

Formats the value using the given formatter.