Enum mz_ore::netio::socket::Listener

pub enum Listener {
    Tcp(TcpListener),
    Unix(UnixListener),
}

Available on crate feature network only.

A listener bound to either a TCP socket or Unix domain socket.

Variants

Tcp(TcpListener)

A TCP listener.

Unix(UnixListener)

A Unix domain socket listener.

Implementations

impl Listener

pub async fn bind<A>(addr: A) -> Result<Listener, Error>

where A: ToSocketAddrs,

Creates a new listener bound to the specified socket address.

If addr is a Unix domain address, this function attempts to unlink the socket at the address, if it exists, before binding.

async fn bind_addr(addr: SocketAddr) -> Result<Listener, Error>

pub async fn accept(&self) -> Result<(Stream, SocketAddr), Error>

Accepts a new incoming connection to this listener.

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

Trait Implementations

impl Debug for Listener

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

Formats the value using the given formatter.

impl Stream for Listener

type Item = Result<Stream, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.