diff --git a/src/server/mod.rs b/src/server/mod.rs index fb65b430a..b080ffe54 100644 --- a/src/server/mod.rs +++ b/src/server/mod.rs @@ -37,5 +37,5 @@ impl Message for StopServer { } /// Socket id token -#[derive(Clone, Copy)] +#[derive(Clone, Copy, Debug)] pub(crate) struct Token(usize); diff --git a/src/server/worker.rs b/src/server/worker.rs index 33d3bc79b..985f68910 100644 --- a/src/server/worker.rs +++ b/src/server/worker.rs @@ -20,7 +20,7 @@ use super::accept::AcceptNotify; use super::services::{BoxedServerService, InternalServerServiceFactory, ServerMessage}; use super::Token; -#[derive(Message)] +#[derive(Debug, Message)] pub(crate) struct Conn { pub io: net::TcpStream, pub handler: Token, @@ -148,7 +148,7 @@ impl Worker { }).and_then(|services, act, ctx| { act.services.extend(services); let mut readiness = CheckReadiness { - avail: true, + avail: false, idx: 0, fut: None, };