| // Copyright Joyent, Inc. and other Node contributors. | 
 | // | 
 | // Permission is hereby granted, free of charge, to any person obtaining a | 
 | // copy of this software and associated documentation files (the | 
 | // "Software"), to deal in the Software without restriction, including | 
 | // without limitation the rights to use, copy, modify, merge, publish, | 
 | // distribute, sublicense, and/or sell copies of the Software, and to permit | 
 | // persons to whom the Software is furnished to do so, subject to the | 
 | // following conditions: | 
 | // | 
 | // The above copyright notice and this permission notice shall be included | 
 | // in all copies or substantial portions of the Software. | 
 | // | 
 | // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS | 
 | // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF | 
 | // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN | 
 | // NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, | 
 | // DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR | 
 | // OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE | 
 | // USE OR OTHER DEALINGS IN THE SOFTWARE. | 
 |  | 
 | 'use strict'; | 
 |  | 
 | var R = typeof Reflect === 'object' ? Reflect : null | 
 | var ReflectApply = R && typeof R.apply === 'function' | 
 |   ? R.apply | 
 |   : function ReflectApply(target, receiver, args) { | 
 |     return Function.prototype.apply.call(target, receiver, args); | 
 |   } | 
 |  | 
 | var ReflectOwnKeys | 
 | if (R && typeof R.ownKeys === 'function') { | 
 |   ReflectOwnKeys = R.ownKeys | 
 | } else if (Object.getOwnPropertySymbols) { | 
 |   ReflectOwnKeys = function ReflectOwnKeys(target) { | 
 |     return Object.getOwnPropertyNames(target) | 
 |       .concat(Object.getOwnPropertySymbols(target)); | 
 |   }; | 
 | } else { | 
 |   ReflectOwnKeys = function ReflectOwnKeys(target) { | 
 |     return Object.getOwnPropertyNames(target); | 
 |   }; | 
 | } | 
 |  | 
 | function ProcessEmitWarning(warning) { | 
 |   if (console && console.warn) console.warn(warning); | 
 | } | 
 |  | 
 | var NumberIsNaN = Number.isNaN || function NumberIsNaN(value) { | 
 |   return value !== value; | 
 | } | 
 |  | 
 | function EventEmitter() { | 
 |   EventEmitter.init.call(this); | 
 | } | 
 | module.exports = EventEmitter; | 
 |  | 
 | // Backwards-compat with node 0.10.x | 
 | EventEmitter.EventEmitter = EventEmitter; | 
 |  | 
 | EventEmitter.prototype._events = undefined; | 
 | EventEmitter.prototype._eventsCount = 0; | 
 | EventEmitter.prototype._maxListeners = undefined; | 
 |  | 
 | // By default EventEmitters will print a warning if more than 10 listeners are | 
 | // added to it. This is a useful default which helps finding memory leaks. | 
 | var defaultMaxListeners = 10; | 
 |  | 
 | Object.defineProperty(EventEmitter, 'defaultMaxListeners', { | 
 |   enumerable: true, | 
 |   get: function() { | 
 |     return defaultMaxListeners; | 
 |   }, | 
 |   set: function(arg) { | 
 |     if (typeof arg !== 'number' || arg < 0 || NumberIsNaN(arg)) { | 
 |       throw new RangeError('The value of "defaultMaxListeners" is out of range. It must be a non-negative number. Received ' + arg + '.'); | 
 |     } | 
 |     defaultMaxListeners = arg; | 
 |   } | 
 | }); | 
 |  | 
 | EventEmitter.init = function() { | 
 |  | 
 |   if (this._events === undefined || | 
 |       this._events === Object.getPrototypeOf(this)._events) { | 
 |     this._events = Object.create(null); | 
 |     this._eventsCount = 0; | 
 |   } | 
 |  | 
 |   this._maxListeners = this._maxListeners || undefined; | 
 | }; | 
 |  | 
 | // Obviously not all Emitters should be limited to 10. This function allows | 
 | // that to be increased. Set to zero for unlimited. | 
 | EventEmitter.prototype.setMaxListeners = function setMaxListeners(n) { | 
 |   if (typeof n !== 'number' || n < 0 || NumberIsNaN(n)) { | 
 |     throw new RangeError('The value of "n" is out of range. It must be a non-negative number. Received ' + n + '.'); | 
 |   } | 
 |   this._maxListeners = n; | 
 |   return this; | 
 | }; | 
 |  | 
 | function $getMaxListeners(that) { | 
 |   if (that._maxListeners === undefined) | 
 |     return EventEmitter.defaultMaxListeners; | 
 |   return that._maxListeners; | 
 | } | 
 |  | 
 | EventEmitter.prototype.getMaxListeners = function getMaxListeners() { | 
 |   return $getMaxListeners(this); | 
 | }; | 
 |  | 
 | EventEmitter.prototype.emit = function emit(type) { | 
 |   var args = []; | 
 |   for (var i = 1; i < arguments.length; i++) args.push(arguments[i]); | 
 |   var doError = (type === 'error'); | 
 |  | 
 |   var 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) { | 
 |     var er; | 
 |     if (args.length > 0) | 
 |       er = args[0]; | 
 |     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 | 
 |     var err = new Error('Unhandled error.' + (er ? ' (' + er.message + ')' : '')); | 
 |     err.context = er; | 
 |     throw err; // Unhandled 'error' event | 
 |   } | 
 |  | 
 |   var handler = events[type]; | 
 |  | 
 |   if (handler === undefined) | 
 |     return false; | 
 |  | 
 |   if (typeof handler === 'function') { | 
 |     ReflectApply(handler, this, args); | 
 |   } else { | 
 |     var len = handler.length; | 
 |     var listeners = arrayClone(handler, len); | 
 |     for (var i = 0; i < len; ++i) | 
 |       ReflectApply(listeners[i], this, args); | 
 |   } | 
 |  | 
 |   return true; | 
 | }; | 
 |  | 
 | function _addListener(target, type, listener, prepend) { | 
 |   var m; | 
 |   var events; | 
 |   var existing; | 
 |  | 
 |   if (typeof listener !== 'function') { | 
 |     throw new TypeError('The "listener" argument must be of type Function. Received type ' + typeof listener); | 
 |   } | 
 |  | 
 |   events = target._events; | 
 |   if (events === undefined) { | 
 |     events = target._events = Object.create(null); | 
 |     target._eventsCount = 0; | 
 |   } else { | 
 |     // To avoid recursion in the case that type === "newListener"! Before | 
 |     // adding it to the listeners, first emit "newListener". | 
 |     if (events.newListener !== undefined) { | 
 |       target.emit('newListener', type, | 
 |                   listener.listener ? listener.listener : listener); | 
 |  | 
 |       // Re-assign `events` because a newListener handler could have caused the | 
 |       // this._events to be assigned to a new object | 
 |       events = target._events; | 
 |     } | 
 |     existing = events[type]; | 
 |   } | 
 |  | 
 |   if (existing === undefined) { | 
 |     // Optimize the case of one listener. Don't need the extra array object. | 
 |     existing = events[type] = listener; | 
 |     ++target._eventsCount; | 
 |   } else { | 
 |     if (typeof existing === 'function') { | 
 |       // Adding the second element, need to change to array. | 
 |       existing = events[type] = | 
 |         prepend ? [listener, existing] : [existing, listener]; | 
 |       // If we've already got an array, just append. | 
 |     } else if (prepend) { | 
 |       existing.unshift(listener); | 
 |     } else { | 
 |       existing.push(listener); | 
 |     } | 
 |  | 
 |     // Check for listener leak | 
 |     m = $getMaxListeners(target); | 
 |     if (m > 0 && existing.length > m && !existing.warned) { | 
 |       existing.warned = true; | 
 |       // No error code for this since it is a Warning | 
 |       // eslint-disable-next-line no-restricted-syntax | 
 |       var w = new Error('Possible EventEmitter memory leak detected. ' + | 
 |                           existing.length + ' ' + String(type) + ' listeners ' + | 
 |                           'added. Use emitter.setMaxListeners() to ' + | 
 |                           'increase limit'); | 
 |       w.name = 'MaxListenersExceededWarning'; | 
 |       w.emitter = target; | 
 |       w.type = type; | 
 |       w.count = existing.length; | 
 |       ProcessEmitWarning(w); | 
 |     } | 
 |   } | 
 |  | 
 |   return target; | 
 | } | 
 |  | 
 | EventEmitter.prototype.addListener = function addListener(type, listener) { | 
 |   return _addListener(this, type, listener, false); | 
 | }; | 
 |  | 
 | EventEmitter.prototype.on = EventEmitter.prototype.addListener; | 
 |  | 
 | EventEmitter.prototype.prependListener = | 
 |     function prependListener(type, listener) { | 
 |       return _addListener(this, type, listener, true); | 
 |     }; | 
 |  | 
 | function onceWrapper() { | 
 |   var args = []; | 
 |   for (var i = 0; i < arguments.length; i++) args.push(arguments[i]); | 
 |   if (!this.fired) { | 
 |     this.target.removeListener(this.type, this.wrapFn); | 
 |     this.fired = true; | 
 |     ReflectApply(this.listener, this.target, args); | 
 |   } | 
 | } | 
 |  | 
 | function _onceWrap(target, type, listener) { | 
 |   var state = { fired: false, wrapFn: undefined, target: target, type: type, listener: listener }; | 
 |   var wrapped = onceWrapper.bind(state); | 
 |   wrapped.listener = listener; | 
 |   state.wrapFn = wrapped; | 
 |   return wrapped; | 
 | } | 
 |  | 
 | EventEmitter.prototype.once = function once(type, listener) { | 
 |   if (typeof listener !== 'function') { | 
 |     throw new TypeError('The "listener" argument must be of type Function. Received type ' + typeof listener); | 
 |   } | 
 |   this.on(type, _onceWrap(this, type, listener)); | 
 |   return this; | 
 | }; | 
 |  | 
 | EventEmitter.prototype.prependOnceListener = | 
 |     function prependOnceListener(type, listener) { | 
 |       if (typeof listener !== 'function') { | 
 |         throw new TypeError('The "listener" argument must be of type Function. Received type ' + typeof listener); | 
 |       } | 
 |       this.prependListener(type, _onceWrap(this, type, listener)); | 
 |       return this; | 
 |     }; | 
 |  | 
 | // Emits a 'removeListener' event if and only if the listener was removed. | 
 | EventEmitter.prototype.removeListener = | 
 |     function removeListener(type, listener) { | 
 |       var list, events, position, i, originalListener; | 
 |  | 
 |       if (typeof listener !== 'function') { | 
 |         throw new TypeError('The "listener" argument must be of type Function. Received type ' + typeof listener); | 
 |       } | 
 |  | 
 |       events = this._events; | 
 |       if (events === undefined) | 
 |         return this; | 
 |  | 
 |       list = events[type]; | 
 |       if (list === undefined) | 
 |         return this; | 
 |  | 
 |       if (list === listener || list.listener === listener) { | 
 |         if (--this._eventsCount === 0) | 
 |           this._events = Object.create(null); | 
 |         else { | 
 |           delete events[type]; | 
 |           if (events.removeListener) | 
 |             this.emit('removeListener', type, list.listener || listener); | 
 |         } | 
 |       } else if (typeof list !== 'function') { | 
 |         position = -1; | 
 |  | 
 |         for (i = list.length - 1; i >= 0; i--) { | 
 |           if (list[i] === listener || list[i].listener === listener) { | 
 |             originalListener = list[i].listener; | 
 |             position = i; | 
 |             break; | 
 |           } | 
 |         } | 
 |  | 
 |         if (position < 0) | 
 |           return this; | 
 |  | 
 |         if (position === 0) | 
 |           list.shift(); | 
 |         else { | 
 |           spliceOne(list, position); | 
 |         } | 
 |  | 
 |         if (list.length === 1) | 
 |           events[type] = list[0]; | 
 |  | 
 |         if (events.removeListener !== undefined) | 
 |           this.emit('removeListener', type, originalListener || listener); | 
 |       } | 
 |  | 
 |       return this; | 
 |     }; | 
 |  | 
 | EventEmitter.prototype.off = EventEmitter.prototype.removeListener; | 
 |  | 
 | EventEmitter.prototype.removeAllListeners = | 
 |     function removeAllListeners(type) { | 
 |       var listeners, events, i; | 
 |  | 
 |       events = this._events; | 
 |       if (events === undefined) | 
 |         return this; | 
 |  | 
 |       // not listening for removeListener, no need to emit | 
 |       if (events.removeListener === undefined) { | 
 |         if (arguments.length === 0) { | 
 |           this._events = Object.create(null); | 
 |           this._eventsCount = 0; | 
 |         } else if (events[type] !== undefined) { | 
 |           if (--this._eventsCount === 0) | 
 |             this._events = Object.create(null); | 
 |           else | 
 |             delete events[type]; | 
 |         } | 
 |         return this; | 
 |       } | 
 |  | 
 |       // emit removeListener for all listeners on all events | 
 |       if (arguments.length === 0) { | 
 |         var keys = Object.keys(events); | 
 |         var key; | 
 |         for (i = 0; i < keys.length; ++i) { | 
 |           key = keys[i]; | 
 |           if (key === 'removeListener') continue; | 
 |           this.removeAllListeners(key); | 
 |         } | 
 |         this.removeAllListeners('removeListener'); | 
 |         this._events = Object.create(null); | 
 |         this._eventsCount = 0; | 
 |         return this; | 
 |       } | 
 |  | 
 |       listeners = events[type]; | 
 |  | 
 |       if (typeof listeners === 'function') { | 
 |         this.removeListener(type, listeners); | 
 |       } else if (listeners !== undefined) { | 
 |         // LIFO order | 
 |         for (i = listeners.length - 1; i >= 0; i--) { | 
 |           this.removeListener(type, listeners[i]); | 
 |         } | 
 |       } | 
 |  | 
 |       return this; | 
 |     }; | 
 |  | 
 | function _listeners(target, type, unwrap) { | 
 |   var events = target._events; | 
 |  | 
 |   if (events === undefined) | 
 |     return []; | 
 |  | 
 |   var evlistener = events[type]; | 
 |   if (evlistener === undefined) | 
 |     return []; | 
 |  | 
 |   if (typeof evlistener === 'function') | 
 |     return unwrap ? [evlistener.listener || evlistener] : [evlistener]; | 
 |  | 
 |   return unwrap ? | 
 |     unwrapListeners(evlistener) : arrayClone(evlistener, evlistener.length); | 
 | } | 
 |  | 
 | EventEmitter.prototype.listeners = function listeners(type) { | 
 |   return _listeners(this, type, true); | 
 | }; | 
 |  | 
 | EventEmitter.prototype.rawListeners = function rawListeners(type) { | 
 |   return _listeners(this, type, false); | 
 | }; | 
 |  | 
 | EventEmitter.listenerCount = function(emitter, type) { | 
 |   if (typeof emitter.listenerCount === 'function') { | 
 |     return emitter.listenerCount(type); | 
 |   } else { | 
 |     return listenerCount.call(emitter, type); | 
 |   } | 
 | }; | 
 |  | 
 | EventEmitter.prototype.listenerCount = listenerCount; | 
 | function listenerCount(type) { | 
 |   var events = this._events; | 
 |  | 
 |   if (events !== undefined) { | 
 |     var evlistener = events[type]; | 
 |  | 
 |     if (typeof evlistener === 'function') { | 
 |       return 1; | 
 |     } else if (evlistener !== undefined) { | 
 |       return evlistener.length; | 
 |     } | 
 |   } | 
 |  | 
 |   return 0; | 
 | } | 
 |  | 
 | EventEmitter.prototype.eventNames = function eventNames() { | 
 |   return this._eventsCount > 0 ? ReflectOwnKeys(this._events) : []; | 
 | }; | 
 |  | 
 | function arrayClone(arr, n) { | 
 |   var copy = new Array(n); | 
 |   for (var i = 0; i < n; ++i) | 
 |     copy[i] = arr[i]; | 
 |   return copy; | 
 | } | 
 |  | 
 | function spliceOne(list, index) { | 
 |   for (; index + 1 < list.length; index++) | 
 |     list[index] = list[index + 1]; | 
 |   list.pop(); | 
 | } | 
 |  | 
 | function unwrapListeners(arr) { | 
 |   var ret = new Array(arr.length); | 
 |   for (var i = 0; i < ret.length; ++i) { | 
 |     ret[i] = arr[i].listener || arr[i]; | 
 |   } | 
 |   return ret; | 
 | } |