Enum mas_listener::unix_or_tcp::UnixOrTcpConnection

pub enum UnixOrTcpConnection {
    Unix {
        stream: UnixStream,
    },
    Tcp {
        stream: TcpStream,
    },
}

Variants

Unix

Fields

stream: UnixStream

Tcp

Fields

stream: TcpStream

Implementations

impl UnixOrTcpConnection

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

Get the local address of the stream

Errors

Returns an error on rare cases where the underlying TcpStream or UnixStream couldn’t provide the local address

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

Get the remote address of the stream

Errors

Returns an error on rare cases where the underlying TcpStream or UnixStream couldn’t provide the remote address

Trait Implementations

impl AsyncRead for UnixOrTcpConnection

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 UnixOrTcpConnection

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

Attempt to write bytes from buf into the object.

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

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.

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

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<(), Error>>

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

impl From<TcpStream> for UnixOrTcpConnection

fn from(stream: TcpStream) -> Self

Converts to this type from the input type.

impl<'__pin> Unpin for UnixOrTcpConnection

where __Origin<'__pin>: Unpin,