stream-worker
Advanced tools
Comparing version 1.0.1 to 1.0.2
{ | ||
"name": "stream-worker", | ||
"version": "1.0.1", | ||
"version": "1.0.2", | ||
"description": "Execute an async function per stream data event, pausing the stream when a concurrency limit is saturated", | ||
@@ -5,0 +5,0 @@ "main": "stream-worker.js", |
@@ -29,2 +29,7 @@ var Promise = require('bluebird'); | ||
function closeHandler () { | ||
closed = true; | ||
completeIfDone(); | ||
} | ||
function finishTask (err) { | ||
@@ -76,8 +81,5 @@ running -= 1; | ||
stream.on('error', errorHandler); | ||
stream.on('close', closeHandler); | ||
stream.on('end', closeHandler); | ||
stream.on('end', function() { | ||
closed = true; | ||
completeIfDone(); | ||
}); | ||
return streamPromise; | ||
@@ -84,0 +86,0 @@ }) |
Sorry, the diff of this file is not supported yet
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
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
13152
74
0