queue - npm Package Compare versions

Comparing version 2.0.0 to 2.1.0

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++;
 };

package.json

 {
   "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" : {

test/concurrent.js

 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() {

test/synchronous.js

 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() {

test/timeout.js

 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() {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This 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 risk

Package 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

Improved metrics

Total package byte prevSize

9294

increased by3.76%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Lines of code

271

decreased by-0.73%

No dependency changes