Struct PipelineInner 

pub struct PipelineInner {
    pub source: Vec<PerlValue>,
    pub ops: Vec<PipelineOp>,
    pub has_scalar_terminal: bool,
    pub par_stream: bool,
    pub streaming: bool,
    pub streaming_workers: usize,
    pub streaming_buffer: usize,
}

Fields

source: Vec<PerlValue>

ops: Vec<PipelineOp>

has_scalar_terminal: bool

Set after preduce / preduce_init / pmap_reduce — no further -> ops allowed.

par_stream: bool

When true (from par_pipeline(LIST)), ->filter / ->map run in parallel with input order preserved on collect().

streaming: bool

When true (from par_pipeline_stream(LIST)), collect() wires ops through bounded channels so items stream between stages concurrently (order not preserved).

streaming_workers: usize

Per-stage worker count for streaming mode (default: available parallelism).

streaming_buffer: usize

Bounded channel capacity for streaming mode (default: 256).

Trait Implementations

impl Debug for PipelineInner

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

Formats the value using the given formatter.