Enum BetaInput 

pub enum BetaInput {
    Alpha(Arc<Mutex<StreamAlphaNode>>),
    Beta(Arc<Mutex<StreamBetaNode>>),
}

Input to a beta node - can be either an alpha node or another beta node This enables nested beta nodes for 3+ stream joins

Variants

Alpha(Arc<Mutex<StreamAlphaNode>>)

Direct alpha node (single stream)

Beta(Arc<Mutex<StreamBetaNode>>)

Nested beta node (already joined streams)

Trait Implementations

impl Clone for BetaInput

fn clone(&self) -> BetaInput

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BetaInput

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

Formats the value using the given formatter.