Enum Control 

pub enum Control {
    Broadcast,
    Unchanged,
    Terminate,
    Sweep,
}

Controls how a node’s execution affects the broader computation graph.

Returned by a node’s cycle function to indicate what should happen after the node completes execution.

Variants

Broadcast

Schedule all nodes with Trigger relationships to this node.

Use when this node has mutated and downstream nodes should react to the changes.

Unchanged

This node did not change - don’t schedule any dependent nodes.

Use when the node has processed data but its state didn’t change in a way that would affect downstream computations.

Terminate

Signal the entire runtime to terminate gracefully.

Use when a critical condition is met and the entire stream processing pipeline should shut down.

Sweep

Mark this node for removal from the graph.

Use when this node has completed its purpose and should be cleaned up. The node will be removed after the current cycle.

Implementations

impl Control

pub fn is_broadcast(&self) -> bool

Returns true if this is a Control::Broadcast, otherwise false

pub fn is_unchanged(&self) -> bool

Returns true if this is a Control::Unchanged, otherwise false

pub fn is_terminate(&self) -> bool

Returns true if this is a Control::Terminate, otherwise false

pub fn is_sweep(&self) -> bool

Returns true if this is a Control::Sweep, otherwise false

Trait Implementations

impl Clone for Control

fn clone(&self) -> Control

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Control

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

Formats the value using the given formatter.

impl From<bool> for Control

fn from(value: bool) -> Self

Converts to this type from the input type.

impl Hash for Control

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Control

fn eq(&self, other: &Control) -> 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 Copy for Control

impl Eq for Control

impl StructuralPartialEq for Control