fix(core): update

This commit is contained in:
2018-12-10 23:41:41 +01:00
parent e98fe56488
commit 4b22e8118b
6 changed files with 232 additions and 31 deletions

View File

@ -3,8 +3,10 @@ import { EventEmitter } from 'events';
export { EventEmitter };
export let once = async <T>(eventEmitter: EventEmitter, eventName: string): Promise<T> => {
let done = plugins.smartpromise.defer<T>();
eventEmitter.once(eventName, done.resolve);
export const once = async <T>(eventEmitter: EventEmitter, eventName: string): Promise<T> => {
const done = plugins.smartpromise.defer<T>();
eventEmitter.once(eventName, eventPayload => {
done.resolve(eventPayload);
});
return await done.promise;
};