diff --git a/actix-utils/src/inflight.rs b/actix-utils/src/inflight.rs index d4751d05..31877d1f 100644 --- a/actix-utils/src/inflight.rs +++ b/actix-utils/src/inflight.rs @@ -106,11 +106,12 @@ where type Future = InFlightServiceResponse; fn poll_ready(&mut self) -> Poll<(), Self::Error> { - let res = self.service.poll_ready(); - if res.is_ok() && !self.count.available() { + let res = self.service.poll_ready()?; + if res.is_ready() && !self.count.available() { + log::trace!("InFlight limit exceeded"); return Ok(Async::NotReady); } - res + Ok(res) } fn call(&mut self, req: Request) -> Self::Future {