Limit async function invocations to one at a time
npm install p-synchronize> Limit async function invocations to one at a time
(with a nod to sindresorhus for https://github.com/sindresorhus/promise-fun)
``
$ npm install p-synchronize
`js
const pSynchronize = require('p-synchronize');
const sync = pSynchronize();
const recalibrate = sync(async (options) => {
// ... some long operation
return options.call;
});
const input = [
recalibrate({call: 1}),
recalibrate({call: 2}),
recalibrate({call: 3}),
];
(async () => {
// Only one recalibration is run at once
const result = await Promise.all(input);
console.log(result);
})();
// --> [1, 2, 3]
`
Returns a synchronizer.
Wraps the enclosed function such that one wrapped function may be executing at any time.
This package is similar, but expresses the one-at-a-time behavior more naturally.
For example, in an object implementing a service, you may want a clean way to shut down the service.
p-synchronize can synchronize multiple functions, so just synchronize an empty function:
`js
class Service {
constructor() {
this.sync = pSynchronize();
this.recalibrate = this.sync(() => this.recalibrate());
}
async stop() {
// ensure no more calls will occur
this.recalibrate = async () => {
throw new Error("Serivce is stopped");
};
// wait for all pending calls to complete
await this.sync(() => {})();
}
}
``