Struct Node 

pub struct Node {
    pub op: Op,
    pub inputs: Vec<OpId>,
    pub because: Option<String>,
    pub per_session: bool,
    pub consumers: usize,
}

Fields

op: Op

inputs: Vec<OpId>

because: Option<String>

Set when this operator is a fallback: which construct had no delta rule.

per_session: bool

True when this node reads the session, directly or through an input. §5.3’s boundary: the nodes for which this is false are the shared dataflow, the rest run per subscriber.

consumers: usize

How many operators read this one. Two or more is §5.3’s shared prefix, at the granularity the engine actually shares at.

Trait Implementations

impl Clone for Node

fn clone(&self) -> Node

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Node

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

Formats the value using the given formatter.