Struct nex_socket::AsyncTcpStream

pub struct AsyncTcpStream { /* private fields */ }

Async TCP Stream.

Implementations

impl AsyncTcpStream

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

Connect to a remote address.

pub async fn connect_timeout( addr: &SocketAddr, timeout: Duration ) -> Result<Self>

Connect to a remote address with timeout.

pub async fn local_addr(&self) -> Result<SocketAddr>

Get local address.

pub async fn peer_addr(&self) -> Result<SocketAddr>

Get peer address.

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

Write data to the socket.

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

Attempts to write an entire buffer into this writer.

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

Read data from the socket.

pub async fn read_to_end(&self, buf: &mut Vec<u8>) -> Result<usize>

Read all bytes until EOF in this source, placing them into buf.

pub async fn read_to_end_timeout( &self, buf: &mut Vec<u8>, timeout: Duration ) -> Result<usize>

Read all bytes until EOF in this source, placing them into buf. This ignore io::Error on read_to_end because it is expected when reading response. If no response is received, and io::Error is occurred, return Err.

pub async fn shutdown(&self, how: Shutdown) -> Result<()>

Shutdown the socket.

pub async fn take_error(&self) -> Result<Option<Error>>

Get the value of the SO_ERROR option on this socket.

pub async fn try_clone(&self) -> Result<Self>

Creates a new independently owned handle to the underlying socket.

pub async fn set_read_timeout(&self, dur: Option<Duration>) -> Result<()>

Sets the read timeout to the timeout specified.

pub async fn set_write_timeout(&self, dur: Option<Duration>) -> Result<()>

Sets the write timeout to the timeout specified.

pub async fn read_timeout(&self) -> Result<Option<Duration>>

Gets the read timeout of this socket.

pub async fn write_timeout(&self) -> Result<Option<Duration>>

Gets the write timeout of this socket.

pub async fn set_nodelay(&self, nodelay: bool) -> Result<()>

Sets the value of the TCP_NODELAY option on this socket.

pub async fn nodelay(&self) -> Result<bool>

Gets the value of the TCP_NODELAY option on this socket.

pub async fn set_ttl(&self, ttl: u32) -> Result<()>

Sets the value for the IP_TTL option on this socket.

pub async fn ttl(&self) -> Result<u32>

Gets the value of the IP_TTL option on this socket.

pub async fn set_nonblocking(&self, nonblocking: bool) -> Result<()>

Moves this TCP stream into or out of nonblocking mode.

Trait Implementations

impl Clone for AsyncTcpStream

fn clone(&self) -> AsyncTcpStream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AsyncTcpStream

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

Formats the value using the given formatter.