diff --git a/chronos/ratelimit.nim b/chronos/ratelimit.nim index 5bf8af9..caaf659 100644 --- a/chronos/ratelimit.nim +++ b/chronos/ratelimit.nim @@ -102,10 +102,6 @@ proc consume*(bucket: TokenBucket, tokens: int): Future[void] = retFuture.complete() return retFuture - bucket.pendingRequests.add(BucketWaiter(future: retFuture, value: tokens)) - if isNil(bucket.workFuture) or bucket.workFuture.finished(): - bucket.workFuture = worker(bucket) - proc cancellation(udata: pointer) = for index in 0..