Efficiently schedules tasks to run as soon as possible without exceeding a specified rate limit. Unlike existing packages, it ensures full utilization of the limit and guarantees adherence to the limit.
The name modrate can be interpreted as moderate or modify rate, whichever is cooler.
npm install modrateimport modrate from "modrate";
const start = Date.now();
function add(a, b) {
console.log(`${Date.now() - start}ms: add(${a}, ${b})`);
return a + b;
}
const interval = 1000;
const limit = 2;
const throttledAdd = modrate.wrap(add, interval, limit);
const promises = [];
promises.push(throttledAdd(1, 2));
await new Promise((resolve) => setTimeout(resolve, 200));
promises.push(throttledAdd(3, 4));
promises.push(throttledAdd(5, 6));
promises.push(throttledAdd(7, 8));
console.log("results:", await Promise.all(promises));Output:
0ms: add(1, 2)
200ms: add(3, 4)
1000ms: add(5, 6)
1200ms: add(7, 8)
results: [ 3, 7, 11, 15 ]
1st and 2nd calls run immediately. The 3rd call runs at 1000ms to avoid three executions within 1000ms. The 4th call runs at 1200ms to prevent three executions (2nd, 3rd, and 4th) within 1000ms.
For more control over waiting and committing the executions, use the Modrate class.
import { Modrate } from "modrate";
const interval = 1000;
const limit = 5;
const modr = new Modrate(interval, limit);
async function process() {
// wait until execution is possible, but throw a TimeoutError if waiting exceeds 2000ms
const done = await modr.wait(AbortSignal.timeout(2000));
//...
if (ok) {
done(); // mark execution as done
} else {
done(false); // don't count the execution
}
//...
}