Struct tokio_uring::net::TcpStream

pub struct TcpStream { /* private fields */ }

A TCP stream between a local and a remote socket.

A TCP stream can either be created by connecting to an endpoint, via the connect method, or by accepting a connection from a listener.

Examples

use tokio_uring::net::TcpStream;
use std::net::ToSocketAddrs;

fn main() -> std::io::Result<()> {
    tokio_uring::start(async {
        // Connect to a peer
        let mut stream = TcpStream::connect("127.0.0.1:8080".parse().unwrap()).await?;

        // Write some data.
        let (result, _) = stream.write(b"hello world!".as_slice()).await;
        result.unwrap();

        Ok(())
    })
}

Implementations

impl TcpStream

pub async fn connect(addr: SocketAddr) -> Result<TcpStream>

Opens a TCP connection to a remote host at the given SocketAddr

pub async fn read<T: IoBufMut>(&self, buf: T) -> BufResult<usize, T>

Read some data from the stream into the buffer, returning the original buffer and quantity of data read.

pub async fn write<T: IoBuf>(&self, buf: T) -> BufResult<usize, T>

Write some data to the stream from the buffer, returning the original buffer and quantity of data written.