queue-event-emitter
Advanced tools
Comparing version 2.0.0 to 2.1.0
@@ -13,9 +13,8 @@ const EventEmitter = require('events') | ||
requestListeners(event) { | ||
let listeners = this._listeners[event] | ||
if (listeners) { | ||
return listeners | ||
} else { | ||
listeners = this._listeners[event] = [] | ||
return listeners | ||
const listeners = this._listeners[event] | ||
if (!listeners) { | ||
this._listeners[event] = [] | ||
return this._listeners[event] | ||
} | ||
return listeners | ||
} | ||
@@ -29,3 +28,3 @@ | ||
const listeners = this.requestListeners(event) | ||
const iterator = (item) => item.listener === listener | ||
const iterator = item => item.listener === listener | ||
const index = listeners.findIndex(iterator) | ||
@@ -36,11 +35,8 @@ if (index > -1) { | ||
return handler.wrapper | ||
} else { | ||
return listener | ||
} | ||
return listener | ||
} | ||
wrap(event, listener) { | ||
const wrapper = (data) => { | ||
return this._queue.add(() => listener(data)) | ||
} | ||
const wrapper = data => this._queue.add(() => listener(data)) | ||
this.saveWrapper(event, listener, wrapper) | ||
@@ -115,3 +111,3 @@ return wrapper | ||
} | ||
rawListeners(event) { | ||
@@ -123,4 +119,4 @@ return this._emitter.rawListeners(event) | ||
return ( | ||
this._queue.getQueueLength() === 0 && | ||
this._queue.getPendingLength() === 0 | ||
this._queue.getQueueLength() === 0 | ||
&& this._queue.getPendingLength() === 0 | ||
) | ||
@@ -127,0 +123,0 @@ } |
{ | ||
"name": "queue-event-emitter", | ||
"version": "2.0.0", | ||
"version": "2.1.0", | ||
"description": "Simple `EventEmitter` which runs every event handler in a queue", | ||
"main": "index.js", | ||
"scripts": { | ||
"test": "mocha" | ||
"test": "mocha", | ||
"lint": "eslint ." | ||
}, | ||
@@ -13,2 +14,9 @@ "repository": { | ||
}, | ||
"keywords": [ | ||
"eventemitter", | ||
"concurrency", | ||
"emitter", | ||
"event", | ||
"queue" | ||
], | ||
"author": { | ||
@@ -28,4 +36,7 @@ "name": "Anton Petrov", | ||
"chai": "^4.1.2", | ||
"eslint": "^4.19.1", | ||
"eslint-config-airbnb-base": "^13.0.0", | ||
"eslint-plugin-import": "^2.13.0", | ||
"mocha": "^5.2.0" | ||
} | ||
} |
@@ -29,4 +29,4 @@ # queue-event-emitter | ||
emitter.on('first', async (data) => { | ||
await sleep(3000) | ||
console.log('data:', data) | ||
await sleep(3000) | ||
console.log('data:', data) | ||
}) | ||
@@ -33,0 +33,0 @@ emitter.on('second', async (data) => { |
Sorry, the diff of this file is not supported yet
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
7398
5
101
1