Struct OutputSender 

pub struct OutputSender { /* private fields */ }

A handle given to a node to send its output packets.

Implementations

impl OutputSender

pub fn new(node_name: String, routing: OutputRouting) -> Self

Creates a new OutputSender. Note: The node_name String is converted to Arc for efficient cloning on the hot path.

pub fn node_name(&self) -> &str

Returns the node’s name.

pub async fn send( &mut self, pin_name: &str, packet: Packet, ) -> Result<(), OutputSendError>

Sends a packet from a specific output pin of this node. Returns Ok(()) if sent successfully.

Nodes should stop processing when this returns an error, as it indicates either a programming mistake (unknown pin) or that the pipeline is shutting down.

Errors

Returns OutputSendError::PinNotFound if the pin doesn’t exist, or OutputSendError::ChannelClosed if the receiving channel is closed.

Trait Implementations

impl Clone for OutputSender

fn clone(&self) -> OutputSender

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.