Struct UnixListener

pub struct UnixListener { /* private fields */ }

UnixListener

Implementations

impl UnixListener

pub fn bind_with_config<P: AsRef<Path>>( path: P, config: &ListenerOpts, ) -> Result<UnixListener>

Creates a new UnixListener bound to the specified socket with custom config.

pub fn bind<P: AsRef<Path>>(path: P) -> Result<UnixListener>

Creates a new UnixListener bound to the specified socket with default config.

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

Accept

pub async fn cancelable_accept( &self, c: CancelHandle, ) -> Result<(UnixStream, SocketAddr)>

Cancelable accept

pub async fn readable(&self, relaxed: bool) -> Result<()>

Wait for read readiness. Note: Do not use it before every io. It is different from other runtimes!

Everytime call to this method may pay a syscall cost. In uring impl, it will push a PollAdd op; in epoll impl, it will use use inner readiness state; if !relaxed, it will call syscall poll after that.

If relaxed, on legacy driver it may return false positive result. If you want to do io by your own, you must maintain io readiness and wait for io ready with relaxed=false.

pub fn from_std(sys_listener: UnixListener) -> Result<Self>

Creates new UnixListener from a std::os::unix::net::UnixListener.

Trait Implementations

impl AsRawFd for UnixListener

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Debug for UnixListener

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

Formats the value using the given formatter.

impl Drop for UnixListener

fn drop(&mut self)

Executes the destructor for this type.

impl IntoRawFd for UnixListener

fn into_raw_fd(self) -> RawFd

Consumes this object, returning the raw underlying file descriptor.

impl Stream for UnixListener

type Item = Result<(UnixStream, SocketAddr), Error>

Values yielded by the stream.

async fn next(&mut self) -> 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.