Struct MapFilterStream 

pub struct MapFilterStream<IN, OUT: Element> { /* private fields */ }

Map’s it’s source into a new Stream using the supplied closure. Used by map.

Implementations

impl<IN, OUT: Element> MapFilterStream<IN, OUT>

pub fn new( upstream: Rc<dyn Stream<IN>>, func: Box<dyn Fn(IN) -> (OUT, bool)>, ) -> Self

Constructs a new MapFilterStream.

Trait Implementations

impl<IN, OUT: Element> MutableNode for MapFilterStream<IN, OUT>

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 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 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 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<IN, OUT: Element> StreamPeekRef<OUT> for MapFilterStream<IN, OUT>

fn peek_ref(&self) -> &OUT

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