Comparing version 2.1.0 to 2.1.1
@@ -54,3 +54,3 @@ var queue = require('..'); | ||
q.on('timeout', function(job, next) { | ||
q.on('timeout', function(next, job) { | ||
console.log('job timed out:', job.toString().replace(/\n/g, '')); | ||
@@ -57,0 +57,0 @@ next(); |
@@ -109,3 +109,3 @@ /** | ||
if (self.listeners('timeout').length > 0) { | ||
self.emit('timeout', job, next); | ||
self.emit('timeout', next, job); | ||
} else { | ||
@@ -112,0 +112,0 @@ next(); |
{ | ||
"name": "queue", | ||
"version": "2.1.0", | ||
"version": "2.1.1", | ||
"description": "async job queue with adjustable concurrency", | ||
@@ -5,0 +5,0 @@ "repository": { |
@@ -65,3 +65,3 @@ ``` | ||
q.on('success', function(job) { | ||
q.on('success', function(result, job) { | ||
console.log('job finished processing:', job.toString().replace(/\n/g, '')); | ||
@@ -107,3 +107,3 @@ }); | ||
q.on('timeout', function(job, next) { | ||
q.on('timeout', function(next, job) { | ||
console.log('job timed out:', job.toString().replace(/\n/g, '')); | ||
@@ -110,0 +110,0 @@ next(); |
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
9302