Trait TcpListenerHandler

pub trait TcpListenerHandler {
    type UserCommand;

    // Required methods
    fn on_start_listen(
        &mut self,
        reactorid: ReactorID,
        cmd_sender: &CmdSender<Self::UserCommand>,
    );
    fn on_new_connection(
        &mut self,
        sock: &mut TcpListener,
        new_sock: &mut TcpStream,
    ) -> Option<NewStreamConnection<Self::UserCommand>>;

    // Provided method
    fn on_close(
        &mut self,
        _reactorid: ReactorID,
        _cmd_sender: &CmdSender<Self::UserCommand>,
    ) { ... }
}

TcpListenerHandler handles incoming connections on a listening socket. Similar to Reactor, it’s destroyed when listening socket is closed.

Required Associated Types

type UserCommand

Required Methods

fn on_start_listen( &mut self, reactorid: ReactorID, cmd_sender: &CmdSender<Self::UserCommand>, )

called when the listen socket starts listeing.

fn on_new_connection( &mut self, sock: &mut TcpListener, new_sock: &mut TcpStream, ) -> Option<NewStreamConnection<Self::UserCommand>>

Provided Methods

fn on_close( &mut self, _reactorid: ReactorID, _cmd_sender: &CmdSender<Self::UserCommand>, )

Implementors

impl TcpListenerHandler for SimpleIoListener

type UserCommand = ()

impl<NewReactor: NewServerReactor + 'static> TcpListenerHandler for DefaultTcpListenerHandler<NewReactor>

type UserCommand = <NewReactor as Reactor>::UserCommand