|
@@ -10,13 +10,17 @@ var Aggregator = module.exports = (function(){
|
|
|
if (typeof docSrcs.length !== "number"){
|
|
if (typeof docSrcs.length !== "number"){
|
|
|
docSrcs = [docSrcs];
|
|
docSrcs = [docSrcs];
|
|
|
}
|
|
}
|
|
|
- this.pipeline = new PipelineCommand(docSrcs, pipelineArgs);
|
|
|
|
|
|
|
+ this.docSrcs = docSrcs;
|
|
|
|
|
+ this.pipelineArgs = pipelineArgs;
|
|
|
};
|
|
};
|
|
|
proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
|
|
proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
|
|
|
|
|
|
|
|
// PROTOTYPE MEMBERS
|
|
// PROTOTYPE MEMBERS
|
|
|
proto.execute = function execute(inputs, callback){
|
|
proto.execute = function execute(inputs, callback){
|
|
|
- this.pipeline.run(inputs,function(err, output){
|
|
|
|
|
|
|
+ //! @ticket #2266: always create a new PipelineCommand just before we use it.
|
|
|
|
|
+ var pipeline = new PipelineCommand(this.docSrcs, this.pipelineArgs);
|
|
|
|
|
+
|
|
|
|
|
+ pipeline.run(inputs,function(err, output){
|
|
|
if (err) return callback(err);
|
|
if (err) return callback(err);
|
|
|
return callback(null, output.result);
|
|
return callback(null, output.result);
|
|
|
});
|
|
});
|