Struct ConditionalRouter 

pub struct ConditionalRouter { /* private fields */ }

A filter node that routes frames to one of two output ports based on a predicate function applied to each incoming frame.

• Output port 0: condition is true
• Output port 1: condition is false

Implementations

impl ConditionalRouter

pub fn new(condition: Box<dyn Fn(&FilterFrame) -> bool + Send + Sync>) -> Self

Create a new conditional router with the given predicate.

The predicate receives a shared reference to the frame and returns true to route to output 0 or false to route to output 1.

pub fn with_id(self, id: NodeId) -> Self

Set the node ID.

pub fn last_route(&self) -> Option<u32>

Return which output port the last frame was routed to.

pub fn route(&self, frame: &FilterFrame) -> u32

Evaluate the condition and return the output port index (0 or 1).

Trait Implementations

impl Node for ConditionalRouter

fn id(&self) -> NodeId

Get the node’s unique identifier.

fn name(&self) -> &str

Get the node’s name.

fn node_type(&self) -> NodeType

Get the node type.

fn state(&self) -> NodeState

Get the current state of the node.

fn set_state(&mut self, state: NodeState) -> GraphResult<()>

Set the node state.

fn inputs(&self) -> &[InputPort]

Get the node’s input ports.

fn outputs(&self) -> &[OutputPort]

Get the node’s output ports.

fn process( &mut self, input: Option<FilterFrame>, ) -> GraphResult<Option<FilterFrame>>

Process available input and produce output.

fn reset(&mut self) -> GraphResult<()>

Reset the node to initial state.

fn initialize(&mut self) -> GraphResult<()>

Initialize the node before processing starts.

fn flush(&mut self) -> GraphResult<Vec<FilterFrame>>

Flush any buffered data.

fn input_port(&self, id: PortId) -> Option<&InputPort>

Get input port by ID.

fn output_port(&self, id: PortId) -> Option<&OutputPort>

Get output port by ID.

fn accepts_input(&self, port_type: PortType) -> bool

Check if node accepts the given port type as input.

fn produces_output(&self, port_type: PortType) -> bool

Check if node produces the given port type as output.