Skip to content

Commit ed52f8d

Browse files
committed
Renamed to commandRead
1 parent 911cf43 commit ed52f8d

File tree

5 files changed

+7
-7
lines changed

5 files changed

+7
-7
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -239,8 +239,8 @@ public AsyncWriteOperation<BulkWriteResult> bulkWrite(final List<? extends Write
239239
return operations.bulkWrite(requests, options);
240240
}
241241

242-
public <TResult> AsyncReadOperation<TResult> runCommand(final Bson command, final Class<TResult> resultClass) {
243-
return operations.runCommand(command, resultClass);
242+
public <TResult> AsyncReadOperation<TResult> commandRead(final Bson command, final Class<TResult> resultClass) {
243+
return operations.commandRead(command, resultClass);
244244
}
245245

246246
public AsyncWriteOperation<Void> dropDatabase() {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -514,7 +514,7 @@ MixedBulkWriteOperation bulkWrite(final List<? extends WriteModel<? extends TDoc
514514
.let(toBsonDocument(options.getLet()));
515515
}
516516

517-
<TResult> CommandReadOperation<TResult> runCommand(final Bson command, final Class<TResult> resultClass) {
517+
<TResult> CommandReadOperation<TResult> commandRead(final Bson command, final Class<TResult> resultClass) {
518518
notNull("command", command);
519519
notNull("resultClass", resultClass);
520520
return new CommandReadOperation<TResult>(namespace.getDatabaseName(), toBsonDocument(command), codecRegistry.get(resultClass));

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -216,8 +216,8 @@ public WriteOperation<BulkWriteResult> bulkWrite(final List<? extends WriteModel
216216
return operations.bulkWrite(requests, options);
217217
}
218218

219-
public <TResult> ReadOperation<TResult> runCommand(final Bson command, final Class<TResult> resultClass) {
220-
return operations.runCommand(command, resultClass);
219+
public <TResult> ReadOperation<TResult> commandRead(final Bson command, final Class<TResult> resultClass) {
220+
return operations.commandRead(command, resultClass);
221221
}
222222

223223
public WriteOperation<Void> dropDatabase() {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ public <R> Publisher<R> runCommand(
236236
return Mono.error(new MongoClientException("Read preference in a transaction must be primary"));
237237
}
238238
return createReadOperationMono(
239-
() -> operations.runCommand(command, clazz), clientSession, notNull("readPreference", readPreference));
239+
() -> operations.commandRead(command, clazz), clientSession, notNull("readPreference", readPreference));
240240
}
241241

242242

driver-sync/src/main/com/mongodb/client/internal/MongoDatabaseImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,7 @@ private <TResult> TResult executeCommand(@Nullable final ClientSession clientSes
194194
if (clientSession != null && clientSession.hasActiveTransaction() && !readPreference.equals(ReadPreference.primary())) {
195195
throw new MongoClientException("Read preference in a transaction must be primary");
196196
}
197-
return executor.execute(operations.runCommand(command, resultClass), readPreference, readConcern, clientSession);
197+
return executor.execute(operations.commandRead(command, resultClass), readPreference, readConcern, clientSession);
198198
}
199199

200200
@Override

0 commit comments

Comments
 (0)