stream-splicer
Advanced tools
Comparing version 1.2.0 to 1.3.0
@@ -158,2 +158,3 @@ var Duplex = require('readable-stream').Duplex; | ||
this.emit('_mutate'); | ||
this.length = this._streams.length; | ||
return removed; | ||
@@ -160,0 +161,0 @@ }; |
{ | ||
"name": "stream-splicer", | ||
"version": "1.2.0", | ||
"version": "1.3.0", | ||
"description": "streaming pipeline with a mutable configuration", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -13,3 +13,3 @@ var pipeline = require('../'); | ||
t.plan(5 + 2 + 5); | ||
t.plan(5 + 2 + 5 + 3); | ||
@@ -25,3 +25,7 @@ var a = split(); | ||
var first = through.obj(function (row, enc, next) { | ||
if (expected.first.length === 2) p.push(second); | ||
if (expected.first.length === 2) { | ||
t.equal(p.length, 5); | ||
p.push(second); | ||
t.equal(p.length, 6); | ||
} | ||
@@ -42,2 +46,4 @@ var ex = expected.first.shift(); | ||
var p = pipeline.obj([ a, b, c, d, first ]); | ||
t.equal(p.length, 5); | ||
p.pipe(through.obj(function (row, enc, next) { | ||
@@ -44,0 +50,0 @@ var ex = expected.output.shift(); |
Sorry, the diff of this file is not supported yet
26306
641
142