Enum PipelineOp 

pub enum PipelineOp {
    Filter(Arc<PerlSub>),
    Map(Arc<PerlSub>),
    Tap(Arc<PerlSub>),
    Take(i64),
    PMap {
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PGrep {
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PFor {
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PMapChunked {
        chunk: i64,
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PSort {
        cmp: Option<Arc<PerlSub>>,
        progress: bool,
    },
    PCache {
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PReduce {
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PReduceInit {
        init: PerlValue,
        sub: Arc<PerlSub>,
        progress: bool,
    },
    PMapReduce {
        map: Arc<PerlSub>,
        reduce: Arc<PerlSub>,
        progress: bool,
    },
}

Operations queued on a PerlValue::pipeline value until collect().

Variants

Filter(Arc<PerlSub>)

Map(Arc<PerlSub>)

Tap(Arc<PerlSub>)

tap / peek — run block for side effects; @_ is the current stage list; value unchanged.

Take(i64)

PMap

Parallel map (pmap) — optional stderr progress bar (same as pmap ..., progress => 1).

Fields

sub: Arc<PerlSub>

progress: bool

PGrep

Parallel grep (pgrep).

Fields

sub: Arc<PerlSub>

progress: bool

PFor

Parallel foreach (pfor) — side effects only; stream order preserved.

Fields

sub: Arc<PerlSub>

progress: bool

PMapChunked

pmap_chunked N { } — chunk size + block.

Fields

chunk: i64

sub: Arc<PerlSub>

progress: bool

PSort

psort / psort { $a <=> $b } — parallel sort.

Fields

cmp: Option<Arc<PerlSub>>

progress: bool

PCache

pcache { } — parallel memoized map.

Fields

sub: Arc<PerlSub>

progress: bool

PReduce

preduce { } — must be last before collect(); collect() returns a scalar.

Fields

sub: Arc<PerlSub>

progress: bool

PReduceInit

preduce_init EXPR, { } — scalar result; must be last before collect().

Fields

init: PerlValue

sub: Arc<PerlSub>

progress: bool

PMapReduce

pmap_reduce { } { } — scalar result; must be last before collect().

Fields

map: Arc<PerlSub>

reduce: Arc<PerlSub>

progress: bool

Trait Implementations

impl Clone for PipelineOp

fn clone(&self) -> PipelineOp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineOp

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

Formats the value using the given formatter.