Fix retryable wrapping.

JAVA-5530

Author: vbabanin

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

@@ -125,7 +125,7 @@
 import static com.mongodb.internal.connection.DualMessageSequences.WritersProviderAndLimitsChecker.WriteResult.FAIL_LIMIT_EXCEEDED;
 import static com.mongodb.internal.connection.DualMessageSequences.WritersProviderAndLimitsChecker.WriteResult.OK_LIMIT_NOT_REACHED;
 import static com.mongodb.internal.operation.AsyncOperationHelper.cursorDocumentToAsyncBatchCursor;
-import static com.mongodb.internal.operation.AsyncOperationHelper.decorateReadWithRetriesAsync;
+import static com.mongodb.internal.operation.AsyncOperationHelper.decorateWriteWithRetriesAsync;
 import static com.mongodb.internal.operation.AsyncOperationHelper.withAsyncSourceAndConnection;
 import static com.mongodb.internal.operation.BulkWriteBatch.logWriteModelDoesNotSupportRetries;
 import static com.mongodb.internal.operation.CommandOperationHelper.commandWriteConcern;
@@ -349,7 +349,7 @@ private void executeBatchAsync(
         RetryState retryState = initialRetryState(retryWritesSetting, timeoutContext);
         BatchEncoder batchEncoder = new BatchEncoder();
 
-        AsyncCallbackSupplier<ExhaustiveClientBulkWriteCommandOkResponse> retryingBatchExecutor = decorateReadWithRetriesAsync(
+        AsyncCallbackSupplier<ExhaustiveClientBulkWriteCommandOkResponse> retryingBatchExecutor = decorateWriteWithRetriesAsync(
                 retryState, operationContext,
                 // Each batch re-selects a server and re-checks out a connection because this is simpler,
                 // and it is allowed by https://jira.mongodb.org/browse/DRIVERS-2502.

driver-reactive-streams/src/main/com/mongodb/reactivestreams/client/MongoCluster.java

@@ -377,7 +377,7 @@ public interface MongoCluster {
      *
      * @param models The {@linkplain ClientNamespacedWriteModel individual write operations}.
      * @return The {@link Publisher} with a single element which could be: The {@link ClientBulkWriteResult} if the operation is successful.
-     * The {@link ClientBulkWriteException} If and only if the operation is unsuccessful or partially unsuccessful,
+     * The {@link ClientBulkWriteException} if and only if the operation is unsuccessful or partially unsuccessful,
      * and there is at least one of the following pieces of information to report:
      * {@link ClientBulkWriteException#getWriteConcernErrors()}, {@link ClientBulkWriteException#getWriteErrors()},
      * {@link ClientBulkWriteException#getPartialResult()}. The {@link MongoException} only if the operation is unsuccessful.
@@ -401,7 +401,7 @@ public interface MongoCluster {
      * @param models The {@linkplain ClientNamespacedWriteModel individual write operations}.
      * @param options The options.
      * @return The {@link Publisher} with a single element which could be: The {@link ClientBulkWriteResult} if the operation is successful.
-     * The {@link ClientBulkWriteException} If and only if the operation is unsuccessful or partially unsuccessful,
+     * The {@link ClientBulkWriteException} if and only if the operation is unsuccessful or partially unsuccessful,
      * and there is at least one of the following pieces of information to report:
      * {@link ClientBulkWriteException#getWriteConcernErrors()}, {@link ClientBulkWriteException#getWriteErrors()},
      * {@link ClientBulkWriteException#getPartialResult()}. The {@link MongoException} only if the operation is unsuccessful.
@@ -429,7 +429,7 @@ Publisher<ClientBulkWriteResult> bulkWrite(
      * @param clientSession The {@linkplain ClientSession client session} with which to associate this operation.
      * @param models The {@linkplain ClientNamespacedWriteModel individual write operations}.
      * @return The {@link Publisher} with a single element which could be: The {@link ClientBulkWriteResult} if the operation is successful.
-     * The {@link ClientBulkWriteException} If and only if the operation is unsuccessful or partially unsuccessful,
+     * The {@link ClientBulkWriteException} if and only if the operation is unsuccessful or partially unsuccessful,
      * and there is at least one of the following pieces of information to report:
      * {@link ClientBulkWriteException#getWriteConcernErrors()}, {@link ClientBulkWriteException#getWriteErrors()},
      * {@link ClientBulkWriteException#getPartialResult()}. The {@link MongoException} only if the operation is unsuccessful.
@@ -456,7 +456,7 @@ Publisher<ClientBulkWriteResult> bulkWrite(
      * @param models The {@linkplain ClientNamespacedWriteModel individual write operations}.
      * @param options The options.
      * @return The {@link Publisher} with a single element which could be: The {@link ClientBulkWriteResult} if the operation is successful.
-     * The {@link ClientBulkWriteException} If and only if the operation is unsuccessful or partially unsuccessful,
+     * The {@link ClientBulkWriteException} if and only if the operation is unsuccessful or partially unsuccessful,
      * and there is at least one of the following pieces of information to report:
      * {@link ClientBulkWriteException#getWriteConcernErrors()}, {@link ClientBulkWriteException#getWriteErrors()},
      * {@link ClientBulkWriteException#getPartialResult()}. The {@link MongoException} only if the operation is unsuccessful.