Struct embassy_net::tcp::TcpReader

pub struct TcpReader<'a> { /* private fields */ }

The reader half of a TCP socket.

Implementations

impl<'a> TcpReader<'a>

pub async fn read(&mut self, buf: &mut [u8]) -> Result<usize, Error>

Read data from the socket.

Returns how many bytes were read, or an error. If no data is available, it waits until there is at least one byte available.

pub async fn read_with<F, R>(&mut self, f: F) -> Result<R, Error>

where F: FnOnce(&mut [u8]) -> (usize, R),

Call f with the largest contiguous slice of octets in the receive buffer, and dequeue the amount of elements returned by f.

If no data is available, it waits until there is at least one byte available.

pub fn recv_capacity(&self) -> usize

Return the maximum number of bytes inside the transmit buffer.

Trait Implementations

impl<'d> ErrorType for TcpReader<'d>

type Error = Error

Error type of all the IO operations on this type.

impl<'d> Read for TcpReader<'d>

async fn read(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error>

Read some bytes from this source into the specified buffer, returning how many bytes were read.

async fn read_exact( &mut self, buf: &mut [u8] ) -> Result<(), ReadExactError<Self::Error>>

Read the exact number of bytes required to fill buf.

impl<'d> ReadReady for TcpReader<'d>

fn read_ready(&mut self) -> Result<bool, Self::Error>

Get whether the reader is ready for immediately reading.