Comparing version 2.1.1 to 2.1.2
18
index.js
@@ -59,5 +59,5 @@ /** | ||
*/ | ||
Queue.prototype.__defineGetter__('length', function() { | ||
return this.pending + this.jobs.length; | ||
}); | ||
Object.defineProperty(Queue.prototype, 'length', { get: function() { | ||
return this.pending + this.jobs.length; | ||
}}); | ||
@@ -93,2 +93,3 @@ /** | ||
} | ||
if (err) { | ||
@@ -99,6 +100,9 @@ self.emit('error', err, job); | ||
} | ||
if (self.pending === 0 && self.jobs.length === 0) { | ||
done.call(self); | ||
} else { | ||
self.start(); | ||
if (self.session === session) { | ||
if (self.pending === 0 && self.jobs.length === 0) { | ||
done.call(self); | ||
} else { | ||
self.start(); | ||
} | ||
} | ||
@@ -105,0 +109,0 @@ } |
{ | ||
"name": "queue", | ||
"version": "2.1.1", | ||
"version": "2.1.2", | ||
"description": "async job queue with adjustable concurrency", | ||
@@ -5,0 +5,0 @@ "repository": { |
require('./synchronous'); | ||
require('./concurrent'); | ||
require('./timeout'); | ||
require('./timeout'); | ||
require('./length'); | ||
require('./error'); | ||
require('./end'); |
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
11497
12
366