Eliminate unnecessary killCursors command when batchSize == limit

driver-core/src/main/com/mongodb/internal/client/model/FindOptions.java

@@ -215,7 +215,9 @@ public FindOptions maxAwaitTime(final long maxAwaitTime, final TimeUnit timeUnit
      * @mongodb.driver.manual reference/method/cursor.batchSize/#cursor.batchSize Batch Size
      */
     public int getBatchSize() {
-        return batchSize;
+        return batchSize > 0 && batchSize == limit
+                ? batchSize + 1 // avoid an open cursor on server side when batchSize and limit are equal
+                : batchSize;
     }
 
     /**

driver-core/src/test/resources/unified-test-format/crud/find.json

@@ -237,6 +237,68 @@
           ]
         }
       ]
+    },
+    {
+      "description": "Find with batchSize equal to limit",
+      "operations": [
+        {
+          "object": "collection0",
+          "name": "find",
+          "arguments": {
+            "filter": {
+              "_id": {
+                "$gt": 1
+              }
+            },
+            "sort": {
+              "_id": 1
+            },
+            "limit": 4,
+            "batchSize": 4
+          },
+          "expectResult": [
+            {
+              "_id": 2,
+              "x": 22
+            },
+            {
+              "_id": 3,
+              "x": 33
+            },
+            {
+              "_id": 4,
+              "x": 44
+            },
+            {
+              "_id": 5,
+              "x": 55
+            }
+          ]
+        }
+      ],
+      "expectEvents": [
+        {
+          "client": "client0",
+          "events": [
+            {
+              "commandStartedEvent": {
+                "command": {
+                  "find": "coll0",
+                  "filter": {
+                    "_id": {
+                      "$gt": 1
+                    }
+                  },
+                  "limit": 4,
+                  "batchSize": 5
+                },
+                "commandName": "find",
+                "databaseName": "find-tests"
+              }
+            }
+          ]
+        }
+      ]
     }
   ]
 }

driver-reactive-streams/src/test/unit/com/mongodb/reactivestreams/client/internal/FindPublisherImplTest.java

@@ -88,7 +88,7 @@ void shouldBuildTheExpectedOperation() {
                 .retryReads(true)
                 .filter(new BsonDocument())
                 .allowDiskUse(false)
-                .batchSize(100)
+                .batchSize(101)
                 .collation(COLLATION)
                 .comment(new BsonString("my comment"))
                 .cursorType(CursorType.NonTailable)

driver-sync/src/test/unit/com/mongodb/client/gridfs/GridFSFindIterableSpecification.groovy

@@ -88,7 +88,7 @@ class GridFSFindIterableSpecification extends Specification {
         expect operation, isTheSameAs(new FindOperation<GridFSFile>(namespace, gridFSFileCodec)
                 .filter(new BsonDocument('filter', new BsonInt32(2)))
                 .sort(new BsonDocument('sort', new BsonInt32(2)))
-                .batchSize(99)
+                .batchSize(100)
                 .limit(99)
                 .skip(9)
                 .noCursorTimeout(true)

driver-sync/src/test/unit/com/mongodb/client/internal/FindIterableSpecification.groovy

@@ -87,7 +87,7 @@ class FindIterableSpecification extends Specification {
                 .filter(new BsonDocument('filter', new BsonInt32(1)))
                 .sort(new BsonDocument('sort', new BsonInt32(1)))
                 .projection(new BsonDocument('projection', new BsonInt32(1)))
-                .batchSize(100)
+                .batchSize(101)
                 .limit(100)
                 .skip(10)
                 .cursorType(CursorType.NonTailable)
@@ -132,7 +132,7 @@ class FindIterableSpecification extends Specification {
                         .filter(new BsonDocument('filter', new BsonInt32(2)))
                         .sort(new BsonDocument('sort', new BsonInt32(2)))
                         .projection(new BsonDocument('projection', new BsonInt32(2)))
-                        .batchSize(99)
+                        .batchSize(100)
                         .limit(99)
                         .skip(9)
                         .cursorType(CursorType.Tailable)