diff --git a/lib/collection.js b/lib/collection.js
index 94fa7eb36d..b293354de4 100644
--- 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