Leaky Bucket

1class LeakyBucket {
2  private queue: number[] = []
3 
4  constructor(private capacity: number, private outRateMs: number) {}
5 
6  /** принимает запрос в момент at, возвращает моменты обработок */
7  accept(at: number, processedAt: number[]): 'queued' | 'dropped' {
8    if (this.queue.length >= this.capacity) return 'dropped'
9    this.queue.push(at)
10    processedAt.push(at)
11    return 'queued'
12  }
13 
14  /** дырка: обработка строго каждые outRateMs */
15  leak(nowMs: number): number {
16    return Math.ceil(nowMs / this.outRateMs) * this.outRateMs
17  }
18}