Struct kernel::kasync::net::TcpStream

source · [−]

pub struct TcpStream { /* private fields */ }

Expand description

A connected TCP socket.

The potentially blocking methods (e.g., TcpStream::read, TcpStream::write) are meant to be used in async contexts.

Examples

async fn echo_server(stream: TcpStream) -> Result {
    let mut buf = [0u8; 1024];
    loop {
        let n = stream.read(&mut buf).await?;
        if n == 0 {
            return Ok(());
        }
        stream.write_all(&buf[..n]).await?;
    }
}

Implementations

source

impl TcpStream

source

pub fn read<'a>(
&'a self,
buf: &'a mut [u8 ]
) -> impl Future<Output = Result<usize>> + 'a

Reads data from a connected socket.

Returns a future that when ready indicates the result of the read operation; on success, it contains the number of bytes read, which will be zero if the connection is closed.

source

pub fn write<'a>(
&'a self,
buf: &'a [u8 ]
) -> impl Future<Output = Result<usize>> + 'a

Writes data to the connected socket.

Returns a future that when ready indicates the result of the write operation; on success, it contains the number of bytes written.

source

pub async fn write_all<'a>(&'a self, buf: &'a [u8 ]) -> Result

Writes all the data to the connected socket.

Returns a future that when ready indicates the result of the write operation; on success, it has written all the data.

Methods from Deref<Target = TcpStream>

source

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

Reads data from a connected socket.

On success, returns the number of bytes read, which will be zero if the connection is closed.

If no data is immediately available for reading, one of two behaviours will occur:

If block is false, returns crate::error::code::EAGAIN;
If block is true, blocks until an error occurs, the connection is closed, or some becomes readable.

source