more tests

Author: fafhrd91

ntex/src/http/client/connector.rs

@@ -344,13 +344,13 @@ where
 
     #[inline]
     fn poll_shutdown(&self, cx: &mut Context<'_>, is_error: bool) -> Poll<()> {
-        let ready = self.tcp_pool.poll_shutdown(cx, is_error).is_ready();
-        let ready = if let Some(ref ssl_pool) = self.ssl_pool {
-            ssl_pool.poll_shutdown(cx, is_error).is_ready() && ready
-        } else {
-            ready
-        };
-        if ready {
+        let tcp_ready = self.tcp_pool.poll_shutdown(cx, is_error).is_ready();
+        let ssl_ready = self
+            .ssl_pool
+            .as_ref()
+            .map(|pool| pool.poll_shutdown(cx, is_error).is_ready())
+            .unwrap_or(true);
+        if tcp_ready && ssl_ready {
             Poll::Ready(())
         } else {
             Poll::Pending

ntex/src/http/client/pool.rs

@@ -666,5 +666,8 @@ mod tests {
         delay_for(Duration::from_millis(50)).await;
         pool.1.borrow_mut().check_availibility();
         assert!(pool.1.borrow().waiters.is_empty());
+
+        assert!(lazy(|cx| pool.poll_ready(cx)).await.is_ready());
+        assert!(lazy(|cx| pool.poll_shutdown(cx, false)).await.is_ready());
     }
 }