| 1 | 'use strict';
|
|---|
| 2 |
|
|---|
| 3 | var has = Object.prototype.hasOwnProperty
|
|---|
| 4 | , prefix = '~';
|
|---|
| 5 |
|
|---|
| 6 | /**
|
|---|
| 7 | * Constructor to create a storage for our `EE` objects.
|
|---|
| 8 | * An `Events` instance is a plain object whose properties are event names.
|
|---|
| 9 | *
|
|---|
| 10 | * @constructor
|
|---|
| 11 | * @private
|
|---|
| 12 | */
|
|---|
| 13 | function Events() {}
|
|---|
| 14 |
|
|---|
| 15 | //
|
|---|
| 16 | // We try to not inherit from `Object.prototype`. In some engines creating an
|
|---|
| 17 | // instance in this way is faster than calling `Object.create(null)` directly.
|
|---|
| 18 | // If `Object.create(null)` is not supported we prefix the event names with a
|
|---|
| 19 | // character to make sure that the built-in object properties are not
|
|---|
| 20 | // overridden or used as an attack vector.
|
|---|
| 21 | //
|
|---|
| 22 | if (Object.create) {
|
|---|
| 23 | Events.prototype = Object.create(null);
|
|---|
| 24 |
|
|---|
| 25 | //
|
|---|
| 26 | // This hack is needed because the `__proto__` property is still inherited in
|
|---|
| 27 | // some old browsers like Android 4, iPhone 5.1, Opera 11 and Safari 5.
|
|---|
| 28 | //
|
|---|
| 29 | if (!new Events().__proto__) prefix = false;
|
|---|
| 30 | }
|
|---|
| 31 |
|
|---|
| 32 | /**
|
|---|
| 33 | * Representation of a single event listener.
|
|---|
| 34 | *
|
|---|
| 35 | * @param {Function} fn The listener function.
|
|---|
| 36 | * @param {*} context The context to invoke the listener with.
|
|---|
| 37 | * @param {Boolean} [once=false] Specify if the listener is a one-time listener.
|
|---|
| 38 | * @constructor
|
|---|
| 39 | * @private
|
|---|
| 40 | */
|
|---|
| 41 | function EE(fn, context, once) {
|
|---|
| 42 | this.fn = fn;
|
|---|
| 43 | this.context = context;
|
|---|
| 44 | this.once = once || false;
|
|---|
| 45 | }
|
|---|
| 46 |
|
|---|
| 47 | /**
|
|---|
| 48 | * Add a listener for a given event.
|
|---|
| 49 | *
|
|---|
| 50 | * @param {EventEmitter} emitter Reference to the `EventEmitter` instance.
|
|---|
| 51 | * @param {(String|Symbol)} event The event name.
|
|---|
| 52 | * @param {Function} fn The listener function.
|
|---|
| 53 | * @param {*} context The context to invoke the listener with.
|
|---|
| 54 | * @param {Boolean} once Specify if the listener is a one-time listener.
|
|---|
| 55 | * @returns {EventEmitter}
|
|---|
| 56 | * @private
|
|---|
| 57 | */
|
|---|
| 58 | function addListener(emitter, event, fn, context, once) {
|
|---|
| 59 | if (typeof fn !== 'function') {
|
|---|
| 60 | throw new TypeError('The listener must be a function');
|
|---|
| 61 | }
|
|---|
| 62 |
|
|---|
| 63 | var listener = new EE(fn, context || emitter, once)
|
|---|
| 64 | , evt = prefix ? prefix + event : event;
|
|---|
| 65 |
|
|---|
| 66 | if (!emitter._events[evt]) emitter._events[evt] = listener, emitter._eventsCount++;
|
|---|
| 67 | else if (!emitter._events[evt].fn) emitter._events[evt].push(listener);
|
|---|
| 68 | else emitter._events[evt] = [emitter._events[evt], listener];
|
|---|
| 69 |
|
|---|
| 70 | return emitter;
|
|---|
| 71 | }
|
|---|
| 72 |
|
|---|
| 73 | /**
|
|---|
| 74 | * Clear event by name.
|
|---|
| 75 | *
|
|---|
| 76 | * @param {EventEmitter} emitter Reference to the `EventEmitter` instance.
|
|---|
| 77 | * @param {(String|Symbol)} evt The Event name.
|
|---|
| 78 | * @private
|
|---|
| 79 | */
|
|---|
| 80 | function clearEvent(emitter, evt) {
|
|---|
| 81 | if (--emitter._eventsCount === 0) emitter._events = new Events();
|
|---|
| 82 | else delete emitter._events[evt];
|
|---|
| 83 | }
|
|---|
| 84 |
|
|---|
| 85 | /**
|
|---|
| 86 | * Minimal `EventEmitter` interface that is molded against the Node.js
|
|---|
| 87 | * `EventEmitter` interface.
|
|---|
| 88 | *
|
|---|
| 89 | * @constructor
|
|---|
| 90 | * @public
|
|---|
| 91 | */
|
|---|
| 92 | function EventEmitter() {
|
|---|
| 93 | this._events = new Events();
|
|---|
| 94 | this._eventsCount = 0;
|
|---|
| 95 | }
|
|---|
| 96 |
|
|---|
| 97 | /**
|
|---|
| 98 | * Return an array listing the events for which the emitter has registered
|
|---|
| 99 | * listeners.
|
|---|
| 100 | *
|
|---|
| 101 | * @returns {Array}
|
|---|
| 102 | * @public
|
|---|
| 103 | */
|
|---|
| 104 | EventEmitter.prototype.eventNames = function eventNames() {
|
|---|
| 105 | var names = []
|
|---|
| 106 | , events
|
|---|
| 107 | , name;
|
|---|
| 108 |
|
|---|
| 109 | if (this._eventsCount === 0) return names;
|
|---|
| 110 |
|
|---|
| 111 | for (name in (events = this._events)) {
|
|---|
| 112 | if (has.call(events, name)) names.push(prefix ? name.slice(1) : name);
|
|---|
| 113 | }
|
|---|
| 114 |
|
|---|
| 115 | if (Object.getOwnPropertySymbols) {
|
|---|
| 116 | return names.concat(Object.getOwnPropertySymbols(events));
|
|---|
| 117 | }
|
|---|
| 118 |
|
|---|
| 119 | return names;
|
|---|
| 120 | };
|
|---|
| 121 |
|
|---|
| 122 | /**
|
|---|
| 123 | * Return the listeners registered for a given event.
|
|---|
| 124 | *
|
|---|
| 125 | * @param {(String|Symbol)} event The event name.
|
|---|
| 126 | * @returns {Array} The registered listeners.
|
|---|
| 127 | * @public
|
|---|
| 128 | */
|
|---|
| 129 | EventEmitter.prototype.listeners = function listeners(event) {
|
|---|
| 130 | var evt = prefix ? prefix + event : event
|
|---|
| 131 | , handlers = this._events[evt];
|
|---|
| 132 |
|
|---|
| 133 | if (!handlers) return [];
|
|---|
| 134 | if (handlers.fn) return [handlers.fn];
|
|---|
| 135 |
|
|---|
| 136 | for (var i = 0, l = handlers.length, ee = new Array(l); i < l; i++) {
|
|---|
| 137 | ee[i] = handlers[i].fn;
|
|---|
| 138 | }
|
|---|
| 139 |
|
|---|
| 140 | return ee;
|
|---|
| 141 | };
|
|---|
| 142 |
|
|---|
| 143 | /**
|
|---|
| 144 | * Return the number of listeners listening to a given event.
|
|---|
| 145 | *
|
|---|
| 146 | * @param {(String|Symbol)} event The event name.
|
|---|
| 147 | * @returns {Number} The number of listeners.
|
|---|
| 148 | * @public
|
|---|
| 149 | */
|
|---|
| 150 | EventEmitter.prototype.listenerCount = function listenerCount(event) {
|
|---|
| 151 | var evt = prefix ? prefix + event : event
|
|---|
| 152 | , listeners = this._events[evt];
|
|---|
| 153 |
|
|---|
| 154 | if (!listeners) return 0;
|
|---|
| 155 | if (listeners.fn) return 1;
|
|---|
| 156 | return listeners.length;
|
|---|
| 157 | };
|
|---|
| 158 |
|
|---|
| 159 | /**
|
|---|
| 160 | * Calls each of the listeners registered for a given event.
|
|---|
| 161 | *
|
|---|
| 162 | * @param {(String|Symbol)} event The event name.
|
|---|
| 163 | * @returns {Boolean} `true` if the event had listeners, else `false`.
|
|---|
| 164 | * @public
|
|---|
| 165 | */
|
|---|
| 166 | EventEmitter.prototype.emit = function emit(event, a1, a2, a3, a4, a5) {
|
|---|
| 167 | var evt = prefix ? prefix + event : event;
|
|---|
| 168 |
|
|---|
| 169 | if (!this._events[evt]) return false;
|
|---|
| 170 |
|
|---|
| 171 | var listeners = this._events[evt]
|
|---|
| 172 | , len = arguments.length
|
|---|
| 173 | , args
|
|---|
| 174 | , i;
|
|---|
| 175 |
|
|---|
| 176 | if (listeners.fn) {
|
|---|
| 177 | if (listeners.once) this.removeListener(event, listeners.fn, undefined, true);
|
|---|
| 178 |
|
|---|
| 179 | switch (len) {
|
|---|
| 180 | case 1: return listeners.fn.call(listeners.context), true;
|
|---|
| 181 | case 2: return listeners.fn.call(listeners.context, a1), true;
|
|---|
| 182 | case 3: return listeners.fn.call(listeners.context, a1, a2), true;
|
|---|
| 183 | case 4: return listeners.fn.call(listeners.context, a1, a2, a3), true;
|
|---|
| 184 | case 5: return listeners.fn.call(listeners.context, a1, a2, a3, a4), true;
|
|---|
| 185 | case 6: return listeners.fn.call(listeners.context, a1, a2, a3, a4, a5), true;
|
|---|
| 186 | }
|
|---|
| 187 |
|
|---|
| 188 | for (i = 1, args = new Array(len -1); i < len; i++) {
|
|---|
| 189 | args[i - 1] = arguments[i];
|
|---|
| 190 | }
|
|---|
| 191 |
|
|---|
| 192 | listeners.fn.apply(listeners.context, args);
|
|---|
| 193 | } else {
|
|---|
| 194 | var length = listeners.length
|
|---|
| 195 | , j;
|
|---|
| 196 |
|
|---|
| 197 | for (i = 0; i < length; i++) {
|
|---|
| 198 | if (listeners[i].once) this.removeListener(event, listeners[i].fn, undefined, true);
|
|---|
| 199 |
|
|---|
| 200 | switch (len) {
|
|---|
| 201 | case 1: listeners[i].fn.call(listeners[i].context); break;
|
|---|
| 202 | case 2: listeners[i].fn.call(listeners[i].context, a1); break;
|
|---|
| 203 | case 3: listeners[i].fn.call(listeners[i].context, a1, a2); break;
|
|---|
| 204 | case 4: listeners[i].fn.call(listeners[i].context, a1, a2, a3); break;
|
|---|
| 205 | default:
|
|---|
| 206 | if (!args) for (j = 1, args = new Array(len -1); j < len; j++) {
|
|---|
| 207 | args[j - 1] = arguments[j];
|
|---|
| 208 | }
|
|---|
| 209 |
|
|---|
| 210 | listeners[i].fn.apply(listeners[i].context, args);
|
|---|
| 211 | }
|
|---|
| 212 | }
|
|---|
| 213 | }
|
|---|
| 214 |
|
|---|
| 215 | return true;
|
|---|
| 216 | };
|
|---|
| 217 |
|
|---|
| 218 | /**
|
|---|
| 219 | * Add a listener for a given event.
|
|---|
| 220 | *
|
|---|
| 221 | * @param {(String|Symbol)} event The event name.
|
|---|
| 222 | * @param {Function} fn The listener function.
|
|---|
| 223 | * @param {*} [context=this] The context to invoke the listener with.
|
|---|
| 224 | * @returns {EventEmitter} `this`.
|
|---|
| 225 | * @public
|
|---|
| 226 | */
|
|---|
| 227 | EventEmitter.prototype.on = function on(event, fn, context) {
|
|---|
| 228 | return addListener(this, event, fn, context, false);
|
|---|
| 229 | };
|
|---|
| 230 |
|
|---|
| 231 | /**
|
|---|
| 232 | * Add a one-time listener for a given event.
|
|---|
| 233 | *
|
|---|
| 234 | * @param {(String|Symbol)} event The event name.
|
|---|
| 235 | * @param {Function} fn The listener function.
|
|---|
| 236 | * @param {*} [context=this] The context to invoke the listener with.
|
|---|
| 237 | * @returns {EventEmitter} `this`.
|
|---|
| 238 | * @public
|
|---|
| 239 | */
|
|---|
| 240 | EventEmitter.prototype.once = function once(event, fn, context) {
|
|---|
| 241 | return addListener(this, event, fn, context, true);
|
|---|
| 242 | };
|
|---|
| 243 |
|
|---|
| 244 | /**
|
|---|
| 245 | * Remove the listeners of a given event.
|
|---|
| 246 | *
|
|---|
| 247 | * @param {(String|Symbol)} event The event name.
|
|---|
| 248 | * @param {Function} fn Only remove the listeners that match this function.
|
|---|
| 249 | * @param {*} context Only remove the listeners that have this context.
|
|---|
| 250 | * @param {Boolean} once Only remove one-time listeners.
|
|---|
| 251 | * @returns {EventEmitter} `this`.
|
|---|
| 252 | * @public
|
|---|
| 253 | */
|
|---|
| 254 | EventEmitter.prototype.removeListener = function removeListener(event, fn, context, once) {
|
|---|
| 255 | var evt = prefix ? prefix + event : event;
|
|---|
| 256 |
|
|---|
| 257 | if (!this._events[evt]) return this;
|
|---|
| 258 | if (!fn) {
|
|---|
| 259 | clearEvent(this, evt);
|
|---|
| 260 | return this;
|
|---|
| 261 | }
|
|---|
| 262 |
|
|---|
| 263 | var listeners = this._events[evt];
|
|---|
| 264 |
|
|---|
| 265 | if (listeners.fn) {
|
|---|
| 266 | if (
|
|---|
| 267 | listeners.fn === fn &&
|
|---|
| 268 | (!once || listeners.once) &&
|
|---|
| 269 | (!context || listeners.context === context)
|
|---|
| 270 | ) {
|
|---|
| 271 | clearEvent(this, evt);
|
|---|
| 272 | }
|
|---|
| 273 | } else {
|
|---|
| 274 | for (var i = 0, events = [], length = listeners.length; i < length; i++) {
|
|---|
| 275 | if (
|
|---|
| 276 | listeners[i].fn !== fn ||
|
|---|
| 277 | (once && !listeners[i].once) ||
|
|---|
| 278 | (context && listeners[i].context !== context)
|
|---|
| 279 | ) {
|
|---|
| 280 | events.push(listeners[i]);
|
|---|
| 281 | }
|
|---|
| 282 | }
|
|---|
| 283 |
|
|---|
| 284 | //
|
|---|
| 285 | // Reset the array, or remove it completely if we have no more listeners.
|
|---|
| 286 | //
|
|---|
| 287 | if (events.length) this._events[evt] = events.length === 1 ? events[0] : events;
|
|---|
| 288 | else clearEvent(this, evt);
|
|---|
| 289 | }
|
|---|
| 290 |
|
|---|
| 291 | return this;
|
|---|
| 292 | };
|
|---|
| 293 |
|
|---|
| 294 | /**
|
|---|
| 295 | * Remove all listeners, or those of the specified event.
|
|---|
| 296 | *
|
|---|
| 297 | * @param {(String|Symbol)} [event] The event name.
|
|---|
| 298 | * @returns {EventEmitter} `this`.
|
|---|
| 299 | * @public
|
|---|
| 300 | */
|
|---|
| 301 | EventEmitter.prototype.removeAllListeners = function removeAllListeners(event) {
|
|---|
| 302 | var evt;
|
|---|
| 303 |
|
|---|
| 304 | if (event) {
|
|---|
| 305 | evt = prefix ? prefix + event : event;
|
|---|
| 306 | if (this._events[evt]) clearEvent(this, evt);
|
|---|
| 307 | } else {
|
|---|
| 308 | this._events = new Events();
|
|---|
| 309 | this._eventsCount = 0;
|
|---|
| 310 | }
|
|---|
| 311 |
|
|---|
| 312 | return this;
|
|---|
| 313 | };
|
|---|
| 314 |
|
|---|
| 315 | //
|
|---|
| 316 | // Alias methods names because people roll like that.
|
|---|
| 317 | //
|
|---|
| 318 | EventEmitter.prototype.off = EventEmitter.prototype.removeListener;
|
|---|
| 319 | EventEmitter.prototype.addListener = EventEmitter.prototype.on;
|
|---|
| 320 |
|
|---|
| 321 | //
|
|---|
| 322 | // Expose the prefix.
|
|---|
| 323 | //
|
|---|
| 324 | EventEmitter.prefixed = prefix;
|
|---|
| 325 |
|
|---|
| 326 | //
|
|---|
| 327 | // Allow `EventEmitter` to be imported as module namespace.
|
|---|
| 328 | //
|
|---|
| 329 | EventEmitter.EventEmitter = EventEmitter;
|
|---|
| 330 |
|
|---|
| 331 | //
|
|---|
| 332 | // Expose the module.
|
|---|
| 333 | //
|
|---|
| 334 | if ('undefined' !== typeof module) {
|
|---|
| 335 | module.exports = EventEmitter;
|
|---|
| 336 | }
|
|---|