We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6ca2efc commit 4e563a8Copy full SHA for 4e563a8
bb8/src/inner.rs
@@ -89,6 +89,10 @@ where
89
loop {
90
let (conn, approvals) = self.inner.pop();
91
self.spawn_replenishing_approvals(approvals);
92
+
93
+ // Cancellation safety: make sure to wrap the connection in a `PooledConnection`
94
+ // before allowing the code to hit an `await`, so we don't lose the connection.
95
96
let mut conn = match conn {
97
Some(conn) => PooledConnection::new(self, conn),
98
None => {
0 commit comments