stream-stream
Advanced tools
Comparing version 1.1.1 to 1.2.0
@@ -8,3 +8,3 @@ var util = require('util'); | ||
this._output = new stream.PassThrough(); | ||
this._output = new stream.PassThrough(options); | ||
this._queue = []; | ||
@@ -35,3 +35,3 @@ | ||
separator = function() { | ||
var ps = new stream.PassThrough(); | ||
var ps = new stream.PassThrough(options); | ||
ps._isSeparator = true; | ||
@@ -60,3 +60,2 @@ fn(function(res) { | ||
var last = this._last(); | ||
var self = this; | ||
if (last) { | ||
@@ -84,4 +83,8 @@ last.once('end', _end.bind(this)); | ||
if(data === null) { | ||
if(this._ended) res = this.push(null); | ||
else res = this.push(''); | ||
if(this._ended) | ||
res = this.push(null); | ||
else if(this._readableState.objectMode) | ||
this._readableState.reading = false; | ||
else | ||
res = this.push(''); | ||
} | ||
@@ -88,0 +91,0 @@ else { |
{ | ||
"name": "stream-stream", | ||
"version": "1.1.1", | ||
"version": "1.2.0", | ||
"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
17068
12
468