Update driver-core/src/main/com/mongodb/internal/operation/AsyncCommandBatchCursor.java

rozza · stIncMale · web-flow · commit 29d6f46f3132 · 2023-11-03T10:12:05.000Z
Co-authored-by: Valentin Kovalenko &lt;valentin.male.kovalenko@gmail.com&gt;
diff --git a/driver-core/src/main/com/mongodb/internal/operation/AsyncCommandBatchCursor.java b/driver-core/src/main/com/mongodb/internal/operation/AsyncCommandBatchCursor.java
@@ -236,7 +236,7 @@ private static final class ResourceManager extends CursorResourceManager<AsyncCo
         <R> AsyncCallbackSupplier<R> execute(final AsyncCallbackSupplier<R> callbackSupplier) {
             return callback -> {
                 if (!tryStartOperation()) {
-                    callback.onResult(null, new IllegalStateException(MESSAGE_IF_CONCURRENT_OPERATION));
+                    callback.onResult(null, new IllegalStateException(MESSAGE_IF_CLOSED_AS_CURSOR));
                 } else {
                     callbackSupplier.whenComplete(this::endOperation).get(callback);
                 }

Original file line number	Diff line number	Diff line change
`@@ -236,7 +236,7 @@ private static final class ResourceManager extends CursorResourceManager<AsyncCo`
`236`	`236`	`<R> AsyncCallbackSupplier<R> execute(final AsyncCallbackSupplier<R> callbackSupplier) {`
`237`	`237`	`return callback -> {`
`238`	`238`	`if (!tryStartOperation()) {`
`239`		`- callback.onResult(null, new IllegalStateException(MESSAGE_IF_CONCURRENT_OPERATION));`
	`239`	`+ callback.onResult(null, new IllegalStateException(MESSAGE_IF_CLOSED_AS_CURSOR));`
`240`	`240`	`} else {`
`241`	`241`	`callbackSupplier.whenComplete(this::endOperation).get(callback);`
`242`	`242`	`}`