Struct dager::edge::Edge

pub struct Edge {
    pub type_id: TypeId,
    pub start_node: Arc<Mutex<dyn AbstAggregator + Send>>,
    pub start_idx: usize,
    pub end_node: Arc<Mutex<dyn AbstAggregator + Send>>,
    pub end_idx: usize,
}

An edge which transports data. The type id can be retrieved at runtime via the type id

Fields

type_id: TypeId

start_node: Arc<Mutex<dyn AbstAggregator + Send>>

start_idx: usize

end_node: Arc<Mutex<dyn AbstAggregator + Send>>

end_idx: usize

Implementations

impl Edge

pub fn connect(
    start: Arc<Mutex<dyn AbstAggregator + Send>>,
    start_idx: usize,
    end: Arc<Mutex<dyn AbstAggregator + Send>>,
    end_idx: usize
) -> Result<(), DErr>

Connects some start node (start) from the output at index start_idx. To the node ends input pin at end_idx.

pub fn send<T>(&self, executor: Arc<Executor>, data: Box<T>) -> Result<(), DErr> where
    T: Any, 

Trait Implementations

impl Clone for Edge

pub fn clone(&self) -> Edge

Returns a copy of the value.

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

Performs copy-assignment from source.