Enum AsyncStream 

pub enum AsyncStream {
    Tcp(TcpStream),
    Unix(UnixStream),
}

An async stream that can be either TCP or Unix Domain Socket.

This enum provides a unified interface for different transport mechanisms, allowing AsyncClient to work with both TCP and Unix Domain Sockets transparently.

Variants

Tcp(TcpStream)

TCP stream for network connections.

Unix(UnixStream)

Unix Domain Socket stream for local IPC (Unix only).

Implementations

impl AsyncStream

pub fn tcp(stream: TcpStream) -> Self

Creates a new TCP stream wrapper.

pub fn unix(stream: UnixStream) -> Self

Creates a new Unix Domain Socket stream wrapper.

pub fn is_tcp(&self) -> bool

Returns true if this is a TCP stream.

pub fn is_unix(&self) -> bool

Returns true if this is a Unix Domain Socket stream.

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

Sets TCP_NODELAY option (only applicable for TCP streams).

Errors

Returns an io::Error from the underlying tokio::net::TcpStream::set_nodelay when the socket option cannot be applied. Unix-domain and named-pipe variants are no-ops that always return Ok(()).

pub fn local_addr_string(&self) -> String

Returns the local address for TCP streams, or a placeholder for Unix sockets.

pub fn peer_addr_string(&self) -> String

Returns the peer address for TCP streams, or a placeholder for Unix sockets.

Trait Implementations

impl AsyncRead for AsyncStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for AsyncStream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Debug for AsyncStream

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

Formats the value using the given formatter.