diff --git a/router/src/batcher.rs b/router/src/batcher.rs index 0c85a406..a9b892cc 100644 --- a/router/src/batcher.rs +++ b/router/src/batcher.rs @@ -70,7 +70,7 @@ impl Batcher { // Notify the background task that we have a new entry in the database that needs // to be batched - self.shared.batching_task.notify_one(); + self.shared.batching_task.notify_waiters(); // Await on the response from the background task // We can safely unwrap as the background task will never drop the sender