Struct dager::node::Aggregator

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

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.

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, 

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

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

pub 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.

pub 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.

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

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

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

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

pub 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.

pub 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, 

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