Struct DataChannel 

pub struct DataChannel { /* private fields */ }

A channel that sends and receives typed protocol messages.

Wraps a raw Channel and provides automatic serialization via ProtocolMessage::encode and ProtocolMessage::decode. Tracks message counts for monitoring.

Implementations

impl DataChannel

pub fn new(channel: Arc<dyn Channel>, node_name: String) -> Self

Create a new DataChannel wrapping the given raw channel.

Arguments

• channel - The underlying channel for byte transport.
• node_name - The name of the peer node on this channel.

pub fn send_message(&self, msg: &ProtocolMessage) -> Result<()>

Send a protocol message through the channel.

The message is encoded to bytes via ProtocolMessage::encode and sent through the underlying channel.

pub fn receive_message( &self, timeout: Duration, ) -> Result<Option<ProtocolMessage>>

Receive a protocol message with a timeout.

Blocks until a message is available or the timeout expires. Returns Ok(None) on timeout.

pub fn get_node_name(&self) -> &str

Get the peer node name.

pub fn messages_sent(&self) -> u64

Get the total number of messages sent.

pub fn messages_received(&self) -> u64

Get the total number of messages received.

pub fn close(&self) -> Result<()>

Close the underlying channel.

pub fn is_open(&self) -> bool

Check if the underlying channel is open.