understream
Advanced tools
Comparing version
@@ -34,2 +34,7 @@ // Generated by CoffeeScript 1.6.3 | ||
} | ||
output = _.extend(output, { | ||
_pipeline: function() { | ||
return streams; | ||
} | ||
}); | ||
return output; | ||
@@ -36,0 +41,0 @@ } |
@@ -248,8 +248,8 @@ // Generated by CoffeeScript 1.6.3 | ||
}) : new HashJoin(this.stream_opts, this.options); | ||
return _.extend(join_instance, { | ||
join_instance = _.extend(join_instance, { | ||
_pipeline: function() { | ||
var _base; | ||
return [join_instance].concat((typeof (_base = _this.options.from)._pipeline === "function" ? _base._pipeline() : void 0) || [_this.options.from]); | ||
return [_this.options.from]; | ||
} | ||
}); | ||
return join_instance; | ||
} | ||
@@ -256,0 +256,0 @@ |
@@ -81,3 +81,7 @@ // Generated by CoffeeScript 1.6.3 | ||
return _.flatten(_(streams).map(function(stream) { | ||
return (typeof stream._pipeline === "function" ? stream._pipeline() : void 0) || [stream]; | ||
if (stream._pipeline != null) { | ||
return pipeline_of_streams(_.without(stream._pipeline(), stream)).concat([stream]); | ||
} else { | ||
return [stream]; | ||
} | ||
})); | ||
@@ -116,2 +120,5 @@ }; | ||
}); | ||
this._pipeline = function() { | ||
return streams; | ||
}; | ||
} | ||
@@ -237,3 +244,3 @@ | ||
_pipeline: function() { | ||
return pipeline_of_streams(streams).concat([last]); | ||
return streams; | ||
} | ||
@@ -244,12 +251,7 @@ }); | ||
Understream.prototype.duplex = function() { | ||
var _this = this; | ||
return _.extend((function(func, args, ctor) { | ||
return (function(func, args, ctor) { | ||
ctor.prototype = func.prototype; | ||
var child = new ctor, result = func.apply(child, args); | ||
return Object(result) === result ? result : child; | ||
})(StreamCombiner, this._streams, function(){}), { | ||
_pipeline: function() { | ||
return pipeline_of_streams(_this._streams); | ||
} | ||
}); | ||
})(StreamCombiner, this._streams, function(){}); | ||
}; | ||
@@ -256,0 +258,0 @@ |
{ | ||
"name": "understream", | ||
"version": "0.10.7", | ||
"version": "0.10.8", | ||
"description": "stream helpers", | ||
@@ -5,0 +5,0 @@ "engines": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
133980
1.32%1274
0.55%