Struct ConcurrencySpec 

pub struct ConcurrencySpec {
    pub producer: Symbol,
    pub sends: Vec<i64>,
    pub receives: usize,
}

A recognized producer/consumer pipe program: a task sends a fixed sequence of integers into a pipe, and main receives them and folds them (first increment: an integer sum) into a shown result.

Fields

producer: Symbol

The task function that sends into the pipe.

sends: Vec<i64>

The integer values the task sends, in order.

receives: usize

How many values main receives (must equal sends.len() for a matched program).

Trait Implementations

impl Clone for ConcurrencySpec

fn clone(&self) -> ConcurrencySpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConcurrencySpec

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

Formats the value using the given formatter.

impl PartialEq for ConcurrencySpec

fn eq(&self, other: &ConcurrencySpec) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ConcurrencySpec

impl StructuralPartialEq for ConcurrencySpec