Trait fizyr_rpc::util::Listener

pub trait Listener {
    type Connection: Debug;
    type Address: Debug;

    // Required method
    fn poll_accept(
        self: Pin<&mut Self>,
        context: &mut Context<'_>
    ) -> Poll<Result<(Self::Connection, Self::Address)>>;

    // Provided method
    fn accept(&mut self) -> Accept<'_, Self> 
       where Self: Unpin { ... }
}

Trait for listeners that can accept new connections.

Required Associated Types

type Connection: Debug

The type of the connections return by the Self::accept() function.

type Address: Debug

The type of the address returned by the Self::accept() function.

Required Methods

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

Try to accept a new connection without blocking.

If no new connection is available, the current task is scheduled to wake up when a new connection is ready.

Provided Methods

fn accept(&mut self) -> Accept<'_, Self>

where Self: Unpin,

Asynchronously accept a new connection.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Listener for UnixSeqpacketListener

type Address = ()

type Connection = UnixSeqpacket

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

impl Listener for TcpListener

type Address = SocketAddr

type Connection = TcpStream

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

impl Listener for UnixListener

type Address = ()

type Connection = UnixStream

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

impl<P> Listener for Pin<P>

where P: DerefMut + Unpin, P::Target: Listener,

type Address = <<P as Deref>::Target as Listener>::Address

type Connection = <<P as Deref>::Target as Listener>::Connection

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

impl<T> Listener for &mut T

where T: Listener + Unpin + ?Sized,

type Address = <T as Listener>::Address

type Connection = <T as Listener>::Connection

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

impl<T> Listener for Box<T>

where T: Listener + Unpin + ?Sized,

type Address = <T as Listener>::Address

type Connection = <T as Listener>::Connection

fn poll_accept( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<(Self::Connection, Self::Address)>>

Implementors