stream-stream
Advanced tools
Comparing version 1.2.4 to 1.2.5
@@ -67,9 +67,11 @@ var util = require('util'); | ||
var self = this; | ||
stream.on('readable', function() { | ||
var chunk; | ||
while(chunk = stream.read()) { | ||
self.push(chunk); | ||
} | ||
function onData (data) { | ||
// TODO pause stream on overrun | ||
self.push(data); | ||
} | ||
stream.on('data', onData); | ||
stream.on('end', function () { | ||
stream.removeListener('data', onData); | ||
done(); | ||
}); | ||
stream.on('end', done); | ||
this._needSeparator = true; | ||
@@ -76,0 +78,0 @@ this._lastStream = stream; |
{ | ||
"name": "stream-stream", | ||
"version": "1.2.4", | ||
"version": "1.2.5", | ||
"description": "A stream of streams in order to concatenates the contents of several streams", | ||
@@ -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
17938
495