Skip to content

Commit be0a78c

Browse files
committed
fies async query
1 parent f5cebc0 commit be0a78c

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoDBDocumentCollectionManagerAsync.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -202,8 +202,7 @@ private void delete(DocumentDeleteQuery query, SingleResultCallback<DeleteResult
202202
String collectionName = query.getDocumentCollection();
203203
com.mongodb.async.client.MongoCollection<Document> asyncCollection =
204204
asyncMongoDatabase.getCollection(collectionName);
205-
Bson mongoDBQuery = DocumentQueryConversor.convert(query.getCondition()
206-
.orElseThrow(() -> new IllegalArgumentException("condition is required")));
205+
Bson mongoDBQuery = query.getCondition().map(DocumentQueryConversor::convert).orElse(EMPTY);;
207206
asyncCollection.deleteMany(mongoDBQuery, callBack);
208207
}
209208

0 commit comments

Comments
 (0)