From 8cdbf49187b1ea7f5039f0f8354fbe18f7424657 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Fri, 1 Feb 2019 15:15:53 -0800
Subject: [PATCH] better inflight readiness check

---
 actix-utils/src/inflight.rs | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

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<T, Request>;
 
     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 {