fix(pool): use .fuse()

This commit is contained in:
Austin Bonander
2024-11-11 12:29:18 -08:00
parent d0f598fc0b
commit 69c071b245

View File

@@ -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! {