atomic-queue
Advanced tools
Comparing version 4.0.0 to 4.0.1
@@ -57,3 +57,3 @@ var events = require('events') | ||
this.stream.on('update-end', function updateEnd (data) { | ||
if (self.pending === 0) self.emit('idle') | ||
if (self.pending === 0) self.stream.emit('idle') | ||
debug('update-end', data) | ||
@@ -60,0 +60,0 @@ self.updatingInflight = false |
{ | ||
"name": "atomic-queue", | ||
"version": "4.0.0", | ||
"version": "4.0.1", | ||
"description": "a crash friendly queue that persists queue state and can restart. uses a worker pool and has configurable concurrency", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
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
11761