Sleep rather than tick

Kuadrant · Apr 30, 2024 · f3a21a4 · f3a21a4
1 parent f393527
commit f3a21a4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/limitador/src/storage/redis/counters_cache.rs b/limitador/src/storage/redis/counters_cache.rs
@@ -169,7 +169,6 @@ impl Batcher {
         F: FnOnce(HashMap<Counter, Arc<CachedCounterValue>>) -> Fut,
         Fut: Future<Output = O>,
     {
-        let mut interval = interval(self.interval);
         let mut ready = self.batch_ready(max);
         loop {
             if ready {
@@ -198,7 +197,7 @@ impl Batcher {
             } else {
                 ready = select! {
                     _ = self.notifier.notified() => self.batch_ready(max),
-                    _ = interval.tick() => true,
+                    _ = tokio::time::sleep(self.interval) => true,
                 }
             }
         }