like-events
Extends events with async for better flow
const LikeEmitter = require('like-events');
const emitter = new LikeEmitter();
emitter.on('change', async function () {
await sleep(1000);
return true;
});
emitter.on('change', async function () {
await sleep(1000);
return false;
});
emitter.emitAll('change').then(console.log);
function sleep (ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
Install
npm i like-events
Features
Description
Extension of native events module (EventEmitter).
Useful for async operations.
Methods
like.emitSync(event: String, ...args): Array
like.emitAll(event: String, ...args): Promise->Array
like.emitSeq(event: String, ...args): Promise->Array
Examples
emitSync
emitter.on('update', function () {
return true;
});
emitter.on('update', function () {
return false;
});
console.log(emitter.emitSync('update'));
[true, false]
emitAll
emitter.on('change', async function () {
console.log('change A1');
await sleep(1000);
console.log('change A2');
return true;
});
emitter.on('change', async function () {
console.log('change B1');
await sleep(1000);
console.log('change B2');
return false;
});
console.log(await emitter.emitAll('change'));
change A1
change B1
sleep +1s
change A2
change B2
[true, false]
emitSeq
emitter.on('processing', async function () {
console.log('processing A');
await sleep(1000);
return 49;
});
emitter.on('processing', async function () {
console.log('processing B');
return 51;
});
console.log(await emitter.emitSeq('processing'));
processing A
sleep +1s
processing B
[49, 51]
Tests
npm test
Issues
Feedback, ideas, etc are very welcome so feel free to open an issue.
License
Code released under the MIT License.