fix(aggregte): support user-provided batchSize

NODE-1415
mongodb · Apr 18, 2018 · ad10dee · ad10dee
1 parent ec6a028
commit ad10dee
Showing 1 changed file with 2 additions and 1 deletion.
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