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(),