Struct TcpListener

pub struct TcpListener { /* private fields */ }

TcpListener

Implementations

impl TcpListener

pub fn bind_with_config<A: ToSocketAddrs>( addr: A, opts: &ListenerOpts, ) -> Result<Self>

Bind to address with config

pub fn bind<A: ToSocketAddrs>(addr: A) -> Result<Self>

Bind to address

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

Accept

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

Cancelable accept

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

Returns the local address that this listener is bound to.

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(stdl: TcpListener) -> Result<Self>

Creates new TcpListener from a std::net::TcpListener.

Trait Implementations

impl AsRawFd for TcpListener

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Debug for TcpListener

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

Formats the value using the given formatter.

impl Drop for TcpListener

fn drop(&mut self)

Executes the destructor for this type.

impl Stream for TcpListener

type Item = Result<(TcpStream, 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.