Socket
Socket
Sign inDemoInstall

queue-event-emitter

Package Overview
Dependencies
1
Maintainers
1
Versions
4
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 2.0.0 to 2.1.0

.eslintrc

26

lib/QueueEventEmitter.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc