We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 79b242d commit 08e1eb0Copy full SHA for 08e1eb0
1 file changed
src/plugins/rate_limiter.rs
@@ -349,7 +349,7 @@ impl TakoPlugin for RateLimiterPlugin {
349
loop {
350
compio::time::sleep(interval).await;
351
let now = Instant::now();
352
- store.retain(|_, b| {
+ store.retain_sync(|_, b| {
353
b.available = (b.available + requests_to_add).min(cfg.max_requests as f64);
354
now.duration_since(b.last_seen) < purge_after
355
});
0 commit comments