|
|
@@ -14,19 +14,19 @@ var PushAccumulator = module.exports = function PushAccumulator(){
|
|
|
}, klass = PushAccumulator, Accumulator = require("./Accumulator"), base = Accumulator, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
|
|
|
|
|
|
proto.processInternal = function processInternal(input, merging) {
|
|
|
- if (!merging) {
|
|
|
- if (input !== undefined) {
|
|
|
- this.values.push(input);
|
|
|
- }
|
|
|
- } else {
|
|
|
- // If we're merging, we need to take apart the arrays we
|
|
|
- // receive and put their elements into the array we are collecting.
|
|
|
- // If we didn't, then we'd get an array of arrays, with one array
|
|
|
- // from each merge source.
|
|
|
+ if (!merging) {
|
|
|
+ if (input !== undefined) {
|
|
|
+ this.values.push(input);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // If we're merging, we need to take apart the arrays we
|
|
|
+ // receive and put their elements into the array we are collecting.
|
|
|
+ // If we didn't, then we'd get an array of arrays, with one array
|
|
|
+ // from each merge source.
|
|
|
if (!Array.isArray(input)) throw new Error("Assertion failure");
|
|
|
|
|
|
Array.prototype.push.apply(this.values, input);
|
|
|
- }
|
|
|
+ }
|
|
|
};
|
|
|
|
|
|
proto.getValue = function getValue(toBeMerged) {
|