Struct Channel 

pub struct Channel {
    pub opened: bool,
    pub setup: bool,
    pub initiator: bool,
    pub xml_reader: XmlReader,
    pub outbox: VecDeque<Vec<u8>>,
}

Communication channel between nodes in the propagation tree.

A Channel manages XML-based message exchange over a transport (typically an SSH pipe). It uses an XmlReader for incoming messages and XML generation for outgoing messages.

Fields

opened: bool

Whether the channel has been opened (received StartMessage).

setup: bool

Whether the channel setup is complete (received ACK to config).

initiator: bool

Whether this end initiated the channel.

xml_reader: XmlReader

The XML reader for parsing incoming data.

outbox: VecDeque<Vec<u8>>

Outgoing message buffer.

Implementations

impl Channel

pub fn new(initiator: bool) -> Self

Create a new Channel.

Arguments

• initiator - true if this end is initiating the channel

pub fn init_xml(&self) -> Vec<u8>

Generate the XML document header.

pub fn open_xml(&self, version: &str) -> Vec<u8>

Generate the opening <channel> tag.

pub fn close_xml(&self) -> Vec<u8>

Generate the closing </channel> tag.

pub fn send(&mut self, msg: &Message)

Serialize a message and enqueue it for sending.

pub fn feed( &mut self, data: &str, ) -> Result<Vec<Message>, MessageProcessingError>

Feed incoming data to the XML reader and return any parsed messages.

pub fn take_outgoing(&mut self) -> Option<Vec<u8>>

Take the next outgoing message from the outbox.

Trait Implementations

impl Debug for Channel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.