Skip to content

Commit e6a0a7e

Browse files
vbabaninstIncMale
andauthored
Apply suggestions from code review
Co-authored-by: Valentin Kovalenko <[email protected]>
1 parent bee199e commit e6a0a7e

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

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

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -269,9 +269,13 @@ public Publisher<ClientBulkWriteResult> bulkWrite(final ClientSession clientSess
269269

270270
@Override
271271
public Publisher<ClientBulkWriteResult> bulkWrite(final ClientSession clientSession,
272-
final List<? extends ClientNamespacedWriteModel> models,
273-
final ClientBulkWriteOptions options) throws ClientBulkWriteException {
274-
return mongoOperationPublisher.clientBulkWrite(clientSession, models, options);
272+
final List<? extends ClientNamespacedWriteModel> clientWriteModels,
273+
final ClientBulkWriteOptions options) {
274+
notNull("clientSession", clientSession);
275+
notNull("clientWriteModels", clientWriteModels);
276+
isTrueArgument("`clientWriteModels` must not be empty", !clientWriteModels.isEmpty());
277+
notNull("options", options);
278+
return mongoOperationPublisher.clientBulkWrite(clientSession, clientWriteModels, options);
275279
}
276280

277281
}

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -292,6 +292,7 @@ Publisher<BulkWriteResult> bulkWrite(
292292
operations::getTimeoutSettings,
293293
() -> operations.bulkWrite(notNull("requests", requests), notNull("options", options)), clientSession);
294294
}
295+
295296
Publisher<ClientBulkWriteResult> clientBulkWrite(
296297
@Nullable final ClientSession clientSession,
297298
final List<? extends ClientNamespacedWriteModel> clientWriteModels,

0 commit comments

Comments
 (0)