diff options
Diffstat (limited to 'src/ratelimiter.go')
| -rw-r--r-- | src/ratelimiter.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ratelimiter.go b/src/ratelimiter.go index 4f8227e..6e5f005 100644 --- a/src/ratelimiter.go +++ b/src/ratelimiter.go @@ -66,11 +66,11 @@ func (rate *Ratelimiter) GarbageCollectEntries() { rate.mutex.Unlock() } -func (rate *Ratelimiter) RoutineGarbageCollector(stop chan struct{}) { +func (rate *Ratelimiter) RoutineGarbageCollector(stop Signal) { timer := time.NewTimer(time.Second) for { select { - case <-stop: + case <-stop.Wait(): return case <-timer.C: rate.GarbageCollectEntries() |