From 8a1949cc197ab2af5964700f3a684c1ba7bf87ad Mon Sep 17 00:00:00 2001 From: vaikzs Date: Mon, 3 Jun 2024 16:28:21 -0700 Subject: [PATCH] fix: fixing notification to waiting clients --- bb8/src/inner.rs | 1 - bb8/src/internals.rs | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) 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) {