"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const events_1 = require("events");
function safeApply(handler, context, args) {
try {
Reflect.apply(handler, context, args);
}
catch (err) {
// Throw error after timeout so as not to interrupt the stack
setTimeout(() => {
throw err;
});
}
}
function arrayClone(arr) {
const n = arr.length;
const copy = new Array(n);
for (let i = 0; i < n; i += 1) {
copy[i] = arr[i];
}
return copy;
}
class SafeEventEmitter extends events_1.EventEmitter {
emit(type, ...args) {
let doError = type === 'error';
const events = this._events;
if (events !== undefined) {
doError = doError && events.error === undefined;
}
else if (!doError) {
return false;
}
// If there is no 'error' event listener then throw.
if (doError) {
let er;
if (args.length > 0) {
[er] = args;
}
if (er instanceof Error) {
// Note: The comments on the `throw` lines are intentional, they show
// up in Node's output if this results in an unhandled exception.
throw er; // Unhandled 'error' event
}
// At least give some kind of context to the user
const err = new Error(`Unhandled error.${er ? ` (${er.message})` : ''}`);
err.context = er;
throw err; // Unhandled 'error' event
}
const handler = events[type];
if (handler === undefined) {
return false;
}
if (typeof handler === 'function') {
safeApply(handler, this, args);
}
else {
const len = handler.length;
const listeners = arrayClone(handler);
for (let i = 0; i < len; i += 1) {
safeApply(listeners[i], this, args);
}
}
return true;
}
}
exports.default = SafeEventEmitter;
//# sourceMappingURL=index.js.map