Skip to content

Commit ab1479c

Browse files
Remove duplicate code for delete all calls.
1 parent 18e9640 commit ab1479c

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/SimpleReactiveMongoRepository.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -276,14 +276,10 @@ public Mono<Void> deleteAll(Iterable<? extends T> entities) {
276276

277277
Assert.notNull(entities, "The given Iterable of entities must not be null");
278278

279-
Collection<?> idCollection = StreamUtils.createStreamFromIterator(entities.iterator()).map(entityInformation::getId)
280-
.collect(Collectors.toList());
279+
Collection<? extends ID> ids = StreamUtils.createStreamFromIterator(entities.iterator())
280+
.map(entityInformation::getId).collect(Collectors.toList());
281281

282-
Criteria idsInCriteria = where(entityInformation.getIdAttribute()).in(idCollection);
283-
284-
Query query = new Query(idsInCriteria);
285-
getReadPreference().ifPresent(query::withReadPreference);
286-
return mongoOperations.remove(query, entityInformation.getJavaType(), entityInformation.getCollectionName()).then();
282+
return deleteAllById(ids);
287283
}
288284

289285
@Override

0 commit comments

Comments
 (0)