Struct UniListener 

pub struct UniListener { /* private fields */ }

A simple wrapper of tokio::net::TcpListener.

Implementations

impl UniListener

pub async fn accept(&self) -> Result<(UniStream, UniAddr)>

Accepts an incoming connection to this listener, and returns the accepted stream and the peer address.

This method will retry on non-deadly errors, including:

• ECONNREFUSED.
• ECONNABORTED.
• ECONNRESET.

pub fn poll_accept( &self, cx: &mut Context<'_>, ) -> Poll<Result<(UniStream, UniAddr)>>

Accepts an incoming connection to this listener, and returns the accepted stream and the peer address.

Notes that on multiple calls to poll_accept, only the waker from the Context passed to the most recent call is scheduled to receive a wakeup. Unless you are implementing your own future accepting connections, you probably want to use the asynchronous accept method instead.

pub fn local_addr(&self) -> Result<UniAddr>

Returns the socket address of the local half of this socket.

This function directly corresponds to the getsockname(2) function on Windows.

Notes

Depending on the OS this may return an error if the socket is not bound.

pub fn as_socket_ref(&self) -> SockRef<'_>

Returns a SockRef to the underlying socket for configuration.

Trait Implementations

impl Debug for UniListener

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

Formats the value using the given formatter.

impl TryFrom<TcpListener> for UniListener

fn try_from(listener: TcpListener) -> Result<Self, Self::Error>

Converts a standard library TCP listener into a unified UniListener.

type Error = Error

The type returned in the event of a conversion error.

impl TryFrom<TcpListener> for UniListener

fn try_from(listener: TcpListener) -> Result<Self, Self::Error>

Converts a Tokio library TCP listener into a unified UniListener.

Errors

Actually, this is infallible and always returns Ok, for APIs consistency.

type Error = Error

The type returned in the event of a conversion error.