0.0.2 • Published 5 years ago
leaky-bucket-queue v0.0.2
leaky-bucket-queue
An implementation of leaky bucket on top of rxjs
.
Simple rate limiting are usually good enough for most scenario but they might incur unnecessary stuttering when there is attempt to make multiple call to a server API. Leaky bucket provides a burstable solution, providing rate limit while allowing bursty traffic, making application more responsive.
Installation
npm i leaky-bucket-queue
Usage
Typescript
import { LeakyBucketQueue } from 'leaky-bucket-queue';
const queue = new LeakyBucketQueue<string>({ burstSize: 5, period: 100 });
queue.consume().subscribe({
next: console.log,
});
queue.enqueue('compter');
...
JavaScript
import { LeakyBucketQueue } from 'leaky-bucket-queue';
const queue = new LeakyBucketQueue({ burstSize: 5, period: 100 });
queue.consume().subscribe({
next: console.log,
});
queue.enqueue('explode');
...