fix(pool): use .fuse()

launchbadge · Nov 11, 2024 · 0f6e085 · 0f6e085
1 parent c2784eb
commit 0f6e085
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sqlx-core/src/pool/inner.rs b/sqlx-core/src/pool/inner.rs
@@ -77,7 +77,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! {