fix(pool): use .fuse()

This commit is contained in:
Austin Bonander 2024-11-11 12:29:18 -08:00
parent 18908e6206
commit 4d73193c39

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