diff --git a/bb8/src/inner.rs b/bb8/src/inner.rs index 7ca6e20..9d109b3 100644 --- a/bb8/src/inner.rs +++ b/bb8/src/inner.rs @@ -141,7 +141,6 @@ where (_, _) => { let approvals = locked.dropped(1, &self.inner.statics); self.spawn_replenishing_approvals(approvals); - self.inner.notify.notify_waiters(); } } } diff --git a/bb8/src/internals.rs b/bb8/src/internals.rs index 59dfe63..1bb3b3c 100644 --- a/bb8/src/internals.rs +++ b/bb8/src/internals.rs @@ -95,7 +95,7 @@ where QueueStrategy::Lifo => self.conns.push_front(conn), } - pool.notify.notify_one(); + pool.notify.notify_waiters(); } pub(crate) fn connect_failed(&mut self, _: Approval) {