Trait lapin::reactor::Reactor

pub trait Reactor: Debug + Send {
    fn register(
        &mut self, 
        socket: &mut TcpStream, 
        socket_state: SocketStateHandle
    ) -> Result<Slot>;

    fn handle(&self) -> Box<dyn ReactorHandle + Send> { ... }
    fn start(self: Box<Self>) -> Result<ThreadHandle> { ... }
}

Required methods

fn register(
    &mut self,
    socket: &mut TcpStream,
    socket_state: SocketStateHandle
) -> Result<Slot>

Provided methods

fn handle(&self) -> Box<dyn ReactorHandle + Send>

fn start(self: Box<Self>) -> Result<ThreadHandle>

Implementors