Trait Node 

pub trait Node: MutableNode {
    // Required methods
    fn cycle(&self, state: &mut GraphState) -> bool;
    fn setup(&self, state: &mut GraphState);
    fn start(&self, state: &mut GraphState);
    fn stop(&self, state: &mut GraphState);
    fn teardown(&self, state: &mut GraphState);
}

A wiring point in the Graph.

Required Methods

fn cycle(&self, state: &mut GraphState) -> bool

This is like Node::cycle but doesn’t require mutable self

fn setup(&self, state: &mut GraphState)

fn start(&self, state: &mut GraphState)

fn stop(&self, state: &mut GraphState)

fn teardown(&self, state: &mut GraphState)

Trait Implementations

impl Display for dyn Node

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

Formats the value using the given formatter.

impl NodeOperators for dyn Node

fn count(self: &Rc<Self>) -> Rc<dyn Stream<u64>>

Running count of the number of times it’s source ticks.

fn ticked_at(self: &Rc<Self>) -> Rc<dyn Stream<NanoTime>>

Emits the time of source ticks in nanos from unix epoch.

fn ticked_at_elapsed(self: &Rc<Self>) -> Rc<dyn Stream<NanoTime>>

Emits the time of source ticks relative to the start.

fn produce<T: Element>( self: &Rc<Self>, func: impl Fn() -> T + 'static, ) -> Rc<dyn Stream<T>>

Emits the result of supplied closure on each upstream tick.

fn run(self: &Rc<Self>, run_mode: RunMode, run_for: RunFor) -> Result<()>

Shortcut for Graph::run i.e. initialise and execute the graph.

fn into_graph(self: &Rc<Self>, run_mode: RunMode, run_for: RunFor) -> Graph

Implementations on Foreign Types

impl<NODE: MutableNode> Node for RefCell<NODE>

fn cycle(&self, state: &mut GraphState) -> bool

fn setup(&self, state: &mut GraphState)

fn start(&self, state: &mut GraphState)

fn stop(&self, state: &mut GraphState)

fn teardown(&self, state: &mut GraphState)

Implementors