Struct IteratorStream 

pub struct IteratorStream<T: Element> { /* private fields */ }

Wraps an Iterator and exposes it as a Stream of Burst<T>. Multiple items with the same timestamp are grouped into a single Burst per tick.

Implementations

impl<T> IteratorStream<T>

where T: Element + 'static,

pub fn new(it: Box<dyn Iterator<Item = ValueAt<T>>>) -> Self

Trait Implementations

impl<T: Element> MutableNode for IteratorStream<T>

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

Called by the graph when it determines that this node is required to be cycled. Returns Ok(true) if the node’s state changed, Ok(false) otherwise.

fn start(&mut self, state: &mut GraphState) -> Result<()>

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 to discover upstream dependencies. Active upstreams trigger this node when they tick; passive are read-only. Defaults to UpStreams::none() (source node). Use #[node(active = [...])] to generate this automatically, or override manually for complex cases.

fn setup(&mut self, state: &mut GraphState) -> Result<()>

called by the graph after wiring and before start

fn stop(&mut self, state: &mut GraphState) -> Result<()>

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

fn teardown(&mut self, state: &mut GraphState) -> Result<()>

fn type_name(&self) -> String

impl<T: Element> StreamPeekRef<TinyVec<[T; 1]>> for IteratorStream<T>

fn peek_ref(&self) -> &Burst<T>

fn clone_from_cell_ref(&self, cell_ref: Ref<'_, T>) -> T