Struct CallBackStream 

pub struct CallBackStream<T: Element + Hash + Eq> { /* private fields */ }

A queue of values that are emitted at specified times. Useful for unit tests. Can also be used to feed stream output back into the Graph as input on later cycles.

Implementations

impl<T: Element + Hash + Eq> CallBackStream<T>

pub fn new() -> Self

Constructs a new CallBackStream.

impl<T: Element + Hash + Eq> CallBackStream<T>

pub fn push(&mut self, value_at: ValueAt<T>)

Trait Implementations

impl<T: Element + Hash + Eq> MutableNode for CallBackStream<T>

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

Called by the graph when it determines that this node is required to be cycled.

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

Called by the graph after wiring and before the first cycle. Can be used to request an initial callback.

fn upstreams(&self) -> UpStreams

Called by the graph at wiring time.

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

called by the graph after wiring and before start

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

Called by the graph after the last cycle. Can be used to clean up resources.

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

fn type_name(&self) -> String

impl<T: Element + Hash + Eq> StreamPeekRef<T> for CallBackStream<T>

fn peek_ref(&self) -> &T