diff --git a/lib/default_stream.js b/lib/default_stream.js index ceb5e5b4..be4fa4bd 100644 --- a/lib/default_stream.js +++ b/lib/default_stream.js @@ -1,9 +1,9 @@ var through = require('through'); -var duplexer = require('duplexer'); +var combine = require('stream-combiner'); var split = require('split'); module.exports = function () { - return duplexer(split(), through(write)); + return combine(split(), through(write)); function write (line) { console.log(line); diff --git a/package.json b/package.json index ace1ac11..92247b69 100644 --- a/package.json +++ b/package.json @@ -12,7 +12,9 @@ "jsonify" : "~0.0.0", "deep-equal" : "~0.1.0", "defined" : "~0.0.0", - "through": "~2.3.4" + "through": "~2.3.4", + "stream-combiner": "~0.0.2", + "split": "~0.2.10" }, "devDependencies" : { "tap" : "~0.3.0",