Skip to content

Commit 3723501

Browse files
committed
Add method in AsyncMongoCollection
Update MongoCollection
1 parent 1fe0ee2 commit 3723501

2 files changed

Lines changed: 9 additions & 0 deletions

File tree

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,15 @@
11
package de.bwaldvogel.mongo;
22

3+
import java.util.List;
34
import java.util.concurrent.CompletionStage;
45

56
import de.bwaldvogel.mongo.backend.QueryParameters;
67
import de.bwaldvogel.mongo.backend.QueryResult;
8+
import de.bwaldvogel.mongo.bson.Document;
79

810
public interface AsyncMongoCollection {
911

1012
CompletionStage<QueryResult> handleQueryAsync(QueryParameters queryData);
13+
14+
CompletionStage<List<Document>> insertDocumentsAsync(List<Document> documents, boolean isOrdered);
1115
}

core/src/main/java/de/bwaldvogel/mongo/MongoCollection.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,11 @@ default List<Document> insertDocuments(List<Document> documents) {
7878

7979
List<Document> insertDocuments(List<Document> documents, boolean isOrdered);
8080

81+
@Override
82+
default CompletionStage<List<Document>> insertDocumentsAsync(List<Document> documents, boolean isOrdered) {
83+
return FutureUtils.wrap(() -> insertDocuments(documents, isOrdered));
84+
}
85+
8186
Document updateDocuments(Document selector, Document update, ArrayFilters arrayFilters,
8287
boolean isMulti, boolean isUpsert, Oplog oplog);
8388

0 commit comments

Comments
 (0)