An implementation of burstable throtling algorithm on top of rxjs
npm install leaky-bucket-queuerxjs.
npm i leaky-bucket-queue
`
Usage
$3
`ts
import { LeakyBucketQueue } from 'leaky-bucket-queue';
const queue = new LeakyBucketQueue({ burstSize: 5, period: 100 });
queue.consume().subscribe({
next: console.log,
});
queue.enqueue('compter');
...
`
$3
`js
import { LeakyBucketQueue } from 'leaky-bucket-queue';
const queue = new LeakyBucketQueue({ burstSize: 5, period: 100 });
queue.consume().subscribe({
next: console.log,
});
queue.enqueue('explode');
...
``