Trait samotop_core::service::tcp::TcpService

pub trait TcpService<IO> {
    type Future: Future<Output = ()> + Send + Sync;
    fn handle(self, io: Result<IO>, connection: Connection) -> Self::Future;
}

An object implementing this trait handles TCP connections in a Future.

The caller would ask the service to handle() the anaccepted io stream and connection (most likely a TcpStream, but abstracted for testability), then poll the returned future to completion. The service may chose to block on the call, effectively preventing concurrent connections, or better to spawn into background and return immediately so that other connections can be received. It could also push back on accepting more connections if it notices too many connections or another resource shortage by blocking on the handle() call.

The SmtpService and DummyTcpService implement this trait.

Associated Types

type Future: Future<Output = ()> + Send + Sync

Loading content...

Required methods

fn handle(self, io: Result<IO>, connection: Connection) -> Self::Future

Loading content...

Implementors

impl<IO> TcpService<IO> for DummyTcpService

type Future = Ready<()>

fn handle(self, _io: Result<IO>, conn: Connection) -> Self::Future

impl<T, IO, P> TcpService<IO> for TlsEnabled<T, P> where
    T: TcpService<TlsCapable<IO, P>>,
    IO: Read + Write + Unpin,
    P: TlsProvider<IO>, 

type Future = T::Future

fn handle(self, io: Result<IO>, conn: Connection) -> Self::Future

Loading content...