Struct Aggregator 

pub struct Aggregator<I: IntoIoSignature, O: IntoIoSignature> { /* private fields */ }

The Aggregator is put “around” some implementation of Node. It handles waiting for data, edge assignment as well as using default data provided by the nodes default() function if no edge is supplied for some port.

Implementations

impl<I, O> Aggregator<I, O>

where I: IntoIoSignature, O: IntoIoSignature,

pub fn from_node<N>(node: N) -> Self

where N: Node<InSig = I, OutSig = O> + Send + 'static,

Creates this aggregator from some Node implementing object. Takes ownership of that node. If that is not desired, use the from_arc() function.

Examples found in repository

examples/math.rs (line 54)

fn main(){
    let ex = Executor::new();
    
    let add_node1 = Arc::new(Mutex::new(Aggregator::from_node(Add)));
    let add_node2 = Arc::new(Mutex::new(Aggregator::from_node(Add)));
    let printer = Arc::new(Mutex::new(Aggregator::from_node(Printer)));
    
    Edge::connect(add_node1.clone(), 0, add_node2.clone(), 1).expect("Failed to connect edge");
    Edge::connect(add_node2.clone(), 0, printer.clone(), 0).expect("Failed to connect edge");
    
    //Should execute since the other edge is set by the default value
    add_node1.lock().unwrap().set_in_from_edge(ex.clone(), 1, Box::new(2.0 as f32)).expect("Failed to set input");

    std::thread::sleep(std::time::Duration::from_secs(1));
}

pub fn from_arc<N>(node: Arc<Mutex<N>>) -> Self

where N: Node<InSig = I, OutSig = O> + Send + 'static,

Trait Implementations

impl<I, O> AbstAggregator for Aggregator<I, O>

where I: IntoIoSignature, O: IntoIoSignature,

fn set_in_edge(&mut self, edge: Edge) -> Result<(), DErr>

fn set_out_edge(&mut self, edge: Edge) -> Result<(), DErr>

fn notify_in_remove(&mut self, port_idx: usize) -> Result<Edge, DErr>

Removes the in edge at port_idx. Returns the removed edge, or why this wasn’t possible.

fn notify_out_remove(&mut self, port_idx: usize) -> Result<Edge, DErr>

Removes the out edge at port_idx. Returns the removed edge, or why this wasn’t possible.

fn set_in_from_edge( &mut self, executor: Arc<Executor>, idx: usize, value: Box<dyn Any>, ) -> Result<(), DErr>

fn set_default_value( &mut self, idx: usize, value: Box<dyn Any>, ) -> Result<(), DErr>

fn in_type_id(&self, in_port_idx: usize) -> Option<TypeId>

fn out_type_id(&self, out_port_idx: usize) -> Option<TypeId>

fn remove_in_edge(&mut self, port_idx: usize) -> Result<(), DErr>

Removes some edge. Should also notify the partner on this edge. Should do nothing, if the node has not edge set at the edge’s end_idx.

fn remove_out_edge(&mut self, port_idx: usize) -> Result<(), DErr>

See remove_in_edge, but in reverse.

impl<O> Executable for Aggregator<(), O>

where O: IntoIoSignature,

fn execute(&mut self, executor: Arc<Executor>) -> Result<(), DErr>