[][src]Trait lapin::reactor::Reactor

pub trait Reactor: Debug + Send {
    pub fn register(
        &mut self,
        socket: &mut TcpStream,
        socket_state: SocketStateHandle
    ) -> Result<Slot>; pub fn handle(&self) -> Box<dyn ReactorHandle + Send> { ... }
pub fn start(self: Box<Self>) -> Result<ThreadHandle> { ... } }

Required methods

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

Loading content...

Provided methods

pub fn handle(&self) -> Box<dyn ReactorHandle + Send>[src]

pub fn start(self: Box<Self>) -> Result<ThreadHandle>[src]

Loading content...

Implementors

Loading content...