fix(aggregte): support user-provided batchSize

mbroadst · mbroadst · commit ad10deef3831 · 2018-04-18T10:45:53.000-04:00
NODE-1415
diff --git a/lib/collection.js b/lib/collection.js
@@ -2430,7 +2430,8 @@ Collection.prototype.aggregate = function(pipeline, options, callback) {
     throw toError('cursor options must be an object');
   }
 
-  options.cursor = options.cursor || { batchSize: 1000 };
+  options.cursor = options.cursor || {};
+  if (options.batchSize) options.cursor.batchSize = options.batchSize;
   command.cursor = options.cursor;
 
   // promiseLibrary

Original file line number	Diff line number	Diff line change
`@@ -2430,7 +2430,8 @@ Collection.prototype.aggregate = function(pipeline, options, callback) {`
`2430`	`2430`	`throw toError('cursor options must be an object');`
`2431`	`2431`	`}`
`2432`	`2432`
`2433`		`- options.cursor = options.cursor \|\| { batchSize: 1000 };`
	`2433`	`+ options.cursor = options.cursor \|\| {};`
	`2434`	`+ if (options.batchSize) options.cursor.batchSize = options.batchSize;`
`2434`	`2435`	`command.cursor = options.cursor;`
`2435`	`2436`
`2436`	`2437`	`// promiseLibrary`