From 4d73193c3914b6a6532003cbbcb6a2cceb87509e Mon Sep 17 00:00:00 2001
From: Austin Bonander <austin.bonander@gmail.com>
Date: Mon, 11 Nov 2024 12:29:18 -0800
Subject: [PATCH] fix(pool): use `.fuse()`

---
 sqlx-core/src/pool/inner.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sqlx-core/src/pool/inner.rs b/sqlx-core/src/pool/inner.rs
index 48270b98..4a515342 100644
--- a/sqlx-core/src/pool/inner.rs
+++ b/sqlx-core/src/pool/inner.rs
@@ -78,7 +78,7 @@ impl<DB: Database> PoolInner<DB> {
 
         // Keep clearing the idle queue as connections are released until the count reaches zero.
         async move {
-            let mut drained = pin!(self.counter.drain());
+            let mut drained = pin!(self.counter.drain()).fuse();
 
             loop {
                 select! {