Trait tls_listener::AsyncAccept

pub trait AsyncAccept {
    type Connection: AsyncRead + AsyncWrite;
    type Error;
    fn poll_accept(
        self: Pin<&mut Self>, 
        cx: &mut Context<'_>
    ) -> Poll<Option<Result<Self::Connection, Self::Error>>>;

    fn until<F: Future>(self, ender: F) -> Until<Self, F>
    where
        Self: Sized,
    { ... }
}

Asynchronously accept connections.

Associated Types

type Connection: AsyncRead + AsyncWrite

The type of the connection that is accepted.

type Error

The type of error that may be returned.

Required methods

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

Poll to accept the next connection.

Provided methods

fn until<F: Future>(self, ender: F) -> Until<Self, F> where
    Self: Sized, 

Return a new AsyncAccept that stops accepting connections after ender completes.

Useful for graceful shutdown.

See examples/echo.rs for example of how to use.

Implementations on Foreign Types

impl AsyncAccept for AddrIncoming

This is supported on crate features hyper-h1 or hyper-h2 only.

type Connection = AddrStream

type Error = Error

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

impl AsyncAccept for TcpListener

This is supported on crate feature tokio-net only.

type Connection = TcpStream

type Error = Error

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

impl AsyncAccept for UnixListener

This is supported on crate feature tokio-net only.

type Connection = UnixStream

type Error = Error

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

Implementors

impl<A: HyperAccept> AsyncAccept for WrappedAccept<A> where
    A::Conn: AsyncRead + AsyncWrite, 

This is supported on crate features hyper-h1 or hyper-h2 only.

type Connection = A::Conn

type Error = A::Error

impl<A: AsyncAccept, E: Future> AsyncAccept for Until<A, E>

type Connection = A::Connection

type Error = A::Error