Trait lapin::reactor::Reactor [−][src]
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> { ... }
}