We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
.fuse()
1 parent 03da18a commit 6ac7b2cCopy full SHA for 6ac7b2c
1 file changed
sqlx-core/src/pool/inner.rs
@@ -78,7 +78,7 @@ impl<DB: Database> PoolInner<DB> {
78
79
// Keep clearing the idle queue as connections are released until the count reaches zero.
80
async move {
81
- let mut drained = pin!(self.counter.drain());
+ let mut drained = pin!(self.counter.drain()).fuse();
82
83
loop {
84
select! {
0 commit comments