berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

fix awc clippy warning

This commit is contained in:
fakeshadow 2021-11-01 16:54:52 +08:00
parent ec6d284a8e
commit 17d7c76843
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
awc/src/client/pool.rs
View File

@ -19,6 +19,7 @@ use actix_rt::time::{sleep, Sleep};
use actix_service::Service; use actix_service::Service;
use ahash::AHashMap; use ahash::AHashMap;
use futures_core::future::LocalBoxFuture; use futures_core::future::LocalBoxFuture;
use futures_util::FutureExt;
use http::uri::Authority; use http::uri::Authority;
use pin_project_lite::pin_project; use pin_project_lite::pin_project;
use tokio::sync::{OwnedSemaphorePermit, Semaphore}; use tokio::sync::{OwnedSemaphorePermit, Semaphore};
@ -201,7 +202,7 @@ where
// check if the connection is still usable // check if the connection is still usable
if let ConnectionInnerType::H1(ref mut io) = c.conn { if let ConnectionInnerType::H1(ref mut io) = c.conn {
let check = ConnectionCheckFuture { io }; let check = ConnectionCheckFuture { io };
match check.await { match check.now_or_never().expect("ConnectionCheckFuture must never yield with Poll::Pending.") {
ConnectionState::Tainted => { ConnectionState::Tainted => {
inner.close(c.conn); inner.close(c.conn);
continue; continue;