From 5ee473459064232ad0486a5171398bd35b014578 Mon Sep 17 00:00:00 2001 From: Pablo Lopez Date: Wed, 16 Jul 2025 20:09:13 +0300 Subject: [PATCH] Apply suggestions from code review Co-authored-by: Ivan FB <128452529+Ivansete-status@users.noreply.github.com> --- ratelimit/rate_limit_manager.nim | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ratelimit/rate_limit_manager.nim b/ratelimit/rate_limit_manager.nim index d7e6997..aceca08 100644 --- a/ratelimit/rate_limit_manager.nim +++ b/ratelimit/rate_limit_manager.nim @@ -86,7 +86,7 @@ proc passToSender[T: Serializable]( proc processCriticalQueue[T: Serializable]( manager: RateLimitManager[T], now: Moment -): Future[void] {.async.} = +) {.async.} = while manager.queueCritical.len > 0: let msgs = manager.queueCritical.popFirst() let capacityState = manager.getCapacityState(now, msgs.len) @@ -101,7 +101,7 @@ proc processCriticalQueue[T: Serializable]( proc processNormalQueue[T: Serializable]( manager: RateLimitManager[T], now: Moment -): Future[void] {.async.} = +) {.async.} = while manager.queueNormal.len > 0: let msgs = manager.queueNormal.popFirst() let capacityState = manager.getCapacityState(now, msgs.len) @@ -161,7 +161,7 @@ proc getEnqueued*[T: Serializable]( return (criticalMsgs, normalMsgs) -proc startQueueHandleLoop*[T: Serializable]( +proc queueHandleLoop[T: Serializable]( manager: RateLimitManager[T], nowProvider: proc(): Moment {.gcsafe.} = proc(): Moment {.gcsafe.} = Moment.now(),