Comparing version 2.0.0 to 2.1.0
14
index.js
@@ -20,2 +20,5 @@ /** | ||
function Queue(options) { | ||
if (!(this instanceof Queue)) | ||
return new Queue(options); | ||
EventEmitter.call(this); | ||
@@ -83,3 +86,3 @@ options = options || {}; | ||
var next = function(err) { | ||
var next = function(err, result) { | ||
if (once && self.session === session) { | ||
@@ -94,3 +97,3 @@ once = false; | ||
} else if (didTimeout === false) { | ||
self.emit('didProcessJob', job); | ||
self.emit('success', result, job); | ||
} | ||
@@ -127,3 +130,3 @@ if (self.pending === 0 && self.jobs.length === 0) { | ||
*/ | ||
Queue.prototype.stop = function() { | ||
Queue.prototype.end = function(err) { | ||
if (this.jobs.length || this.pending) { | ||
@@ -133,2 +136,3 @@ this.jobs = []; | ||
this.session++; | ||
done.call(this, err); | ||
} | ||
@@ -140,5 +144,5 @@ }; | ||
*/ | ||
function done() { | ||
this.emit('end', this); | ||
function done(err) { | ||
this.emit('end', err); | ||
this.session++; | ||
}; |
{ | ||
"name": "queue", | ||
"version": "2.0.0", | ||
"version": "2.1.0", | ||
"description": "async job queue with adjustable concurrency", | ||
@@ -16,3 +16,4 @@ "repository": { | ||
"scripts":{ | ||
"test": "node test" | ||
"test": "node test", | ||
"example": "node example" | ||
}, | ||
@@ -19,0 +20,0 @@ "testling" : { |
var tape = require('tape'); | ||
var Queue = require('..'); | ||
var queue = require('..'); | ||
@@ -8,3 +8,3 @@ tape('concurrent', function(t) { | ||
var actual = []; | ||
var q = new Queue({ concurrency: 100 }); | ||
var q = queue({ concurrency: 100 }); | ||
@@ -11,0 +11,0 @@ q.on('end', function() { |
var tape = require('tape'); | ||
var Queue = require('..'); | ||
var queue = require('..'); | ||
@@ -8,3 +8,3 @@ tape('synchronous', function(t) { | ||
var actual = []; | ||
var q = new Queue(); | ||
var q = queue(); | ||
@@ -11,0 +11,0 @@ q.on('end', function() { |
var tape = require('tape'); | ||
var Queue = require('..'); | ||
var queue = require('..'); | ||
@@ -8,3 +8,3 @@ tape('timeout', function(t) { | ||
var actual = []; | ||
var q = new Queue({ timeout: 100 }); | ||
var q = queue({ timeout: 100 }); | ||
@@ -11,0 +11,0 @@ q.on('end', function() { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
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
9294
0
271