Struct RecvStream 

pub struct RecvStream<R = OwnedReadHalf> { /* private fields */ }

Framed receive stream for length-delimited messages.

Generic over the underlying reader type - works with TCP, TLS, or any AsyncRead.

Implementations

impl<R: AsyncRead + Unpin> RecvStream<R>

pub fn new(stream: R) -> Self

pub async fn recv_object<T: DeserializeOwned>(&mut self) -> Result<Option<T>>

pub async fn copy_to<W: AsyncWrite + Unpin>( &mut self, writer: &mut W, ) -> Result<u64>

Copies data to a writer using the default buffer size (8 KiB).

For better performance with large files, use Self::copy_to_buffered instead.

pub async fn copy_to_buffered<W: AsyncWrite + Unpin>( &mut self, writer: &mut W, buffer_size: usize, ) -> Result<u64>

Copies data to a writer using a custom buffer size.

Uses a buffered reader around the TCP stream with the specified capacity. This avoids the default 8 KiB buffer in tokio::io::copy and can significantly improve throughput on high-bandwidth networks.

pub async fn copy_exact_to_buffered<W: AsyncWrite + Unpin>( &mut self, writer: &mut W, size: u64, buffer_size: usize, ) -> Result<u64>

Copies exactly size bytes to a writer using a custom buffer size.

Unlike Self::copy_to_buffered, this does NOT read until EOF. It reads exactly the specified number of bytes, leaving the stream open for reading subsequent messages.

pub async fn close(&mut self)

Trait Implementations

impl<R: Debug> Debug for RecvStream<R>

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

Formats the value using the given formatter.