Trait poem::listener::Listener

pub trait Listener: Send {
    type Acceptor: Acceptor;
    fn into_acceptor<'async_trait>(
        self
    ) -> Pin<Box<dyn Future<Output = IoResult<Self::Acceptor>> + Send + 'async_trait>>
    where
        Self: 'async_trait;

    fn combine<T>(self, other: T) -> Combined<Self, T>
    where
        Self: Sized,
    { ... }
    fn rustls<S: IntoTlsConfigStream<RustlsConfig>>(
        self, 
        config_stream: S
    ) -> RustlsListener<Self, S>
    where
        Self: Sized,
    { ... }
    fn native_tls<S: IntoTlsConfigStream<NativeTlsConfig>>(
        self, 
        config_stream: S
    ) -> NativeTlsListener<Self, S>
    where
        Self: Sized,
    { ... }
}

Represents a listener that can be listens for incoming connections.

Associated Types

type Acceptor: Acceptor

The acceptor type.

Required methods

fn into_acceptor<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = IoResult<Self::Acceptor>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Create a acceptor instance.

Provided methods

fn combine<T>(self, other: T) -> Combined<Self, T> where
    Self: Sized, 

Combine two listeners.

You can call this function multiple times to combine more listeners.

Example

use poem::listener::{Listener, TcpListener};

let listener = TcpListener::bind("127.0.0.1:80").combine(TcpListener::bind("127.0.0.1:81"));

fn rustls<S: IntoTlsConfigStream<RustlsConfig>>(
    self,
    config_stream: S
) -> RustlsListener<Self, S> where
    Self: Sized, 

This is supported on crate feature rustls only.

Consume this listener and return a new TLS listener with rustls.

fn native_tls<S: IntoTlsConfigStream<NativeTlsConfig>>(
    self,
    config_stream: S
) -> NativeTlsListener<Self, S> where
    Self: Sized, 

This is supported on crate feature native-tls only.

Consume this listener and return a new TLS listener with native-tls.

Implementations on Foreign Types

impl Listener for Infallible

type Acceptor = Infallible

fn into_acceptor<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = IoResult<Self::Acceptor>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Implementors

impl<A: Listener, B: Listener> Listener for Combined<A, B>

type Acceptor = Combined<A::Acceptor, B::Acceptor>

impl<T: AsRef<Path> + Send> Listener for UnixListener<T>

type Acceptor = UnixAcceptor

impl<T: ToSocketAddrs + Send> Listener for TcpListener<T>

type Acceptor = TcpAcceptor

impl<T: Listener, S: IntoTlsConfigStream<NativeTlsConfig>> Listener for NativeTlsListener<T, S>

type Acceptor = NativeTlsAcceptor<T::Acceptor, BoxStream<'static, NativeTlsConfig>>

impl<T: Listener, S: IntoTlsConfigStream<RustlsConfig>> Listener for RustlsListener<T, S>

type Acceptor = RustlsAcceptor<T::Acceptor, BoxStream<'static, RustlsConfig>>