Struct SendStream 

pub struct SendStream<W = OwnedWriteHalf> { /* private fields */ }

Framed send stream for length-delimited messages.

Generic over the underlying writer type - works with TCP, TLS, or any AsyncWrite.

Implementations

impl<W: AsyncWrite + Unpin> SendStream<W>

pub fn new(stream: W) -> Self

pub async fn send_batch_message<T: Serialize>(&mut self, obj: &T) -> Result<()>

pub async fn send_control_message<T: Serialize>( &mut self, obj: &T, ) -> Result<()>

pub async fn send_message_with_data_buffered<T: Serialize, R: AsyncBufRead + Unpin>( &mut self, obj: &T, reader: &mut R, ) -> Result<u64>

Sends an object followed by data from a buffered reader.

This method uses copy_buf which avoids internal buffer allocation by using the reader’s existing buffer. Wrap your reader in BufReader::with_capacity(size, reader) to control the buffer size.

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

Trait Implementations

impl<W: Debug> Debug for SendStream<W>

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

Formats the value using the given formatter.