Struct links_nonblocking::core::messenger::MessageSender

pub struct MessageSender<M: Messenger, const MAX_MSG_SIZE: usize> { /* private fields */ }

Represents an abstraction for sending exactly one message utilizing the underlying FrameWriter

Implementations

impl<M: Messenger, const MAX_MSG_SIZE: usize> MessageSender<M, MAX_MSG_SIZE>

pub fn new(con_id: ConId, stream: TcpStream) -> Self

Trait Implementations

impl<M: Debug + Messenger, const MAX_MSG_SIZE: usize> Debug for MessageSender<M, MAX_MSG_SIZE>

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

Formats the value using the given formatter.

impl<M: Messenger, const MAX_MSG_SIZE: usize> Display for MessageSender<M, MAX_MSG_SIZE>

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

Formats the value using the given formatter.

impl<M: Messenger, const MAX_MSG_SIZE: usize> SendNonBlockingNonMut<<M as Messenger>::SendT> for MessageSender<M, MAX_MSG_SIZE>

fn send_busywait_timeout( &mut self, msg: &<M as Messenger>::SendT, timeout: Duration ) -> Result<SendStatus, Error>

This implementation overrides default trait implementation by optimizing serialization of the message to only happen once in the event that the under socket is busy and returns SendStatus::WouldBlock

fn send_busywait(&mut self, msg: &<M as Messenger>::SendT) -> Result<(), Error>

This implementation overrides default trait implementation by optimizing serialization of the message to only happen once in the event that the under socket is busy and returns SendStatus::WouldBlock

fn send(&mut self, msg: &<M as Messenger>::SendT) -> Result<SendStatus, Error>

The call will internally serialize the msg and attempt to write the resulting bytes into a stream. If there was a successfull attempt which wrote some bytes from serialized message into the stream but the write was only partial then the call will busy wait until all of remaining bytes were written before returning SendStatus::Completed. SendStatus::WouldBlock is returned only if the attempt did not write any bytes to the stream after the first attempt