introduce bulk addDocuments to MongoCollection

Author: jmoghisi

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

@@ -35,6 +35,10 @@ default String getFullName() {
 
     void addDocument(Document document);
 
+    default void addDocuments(List<Document> documents) {
+        documents.forEach(this::addDocument);
+    }
+
     void removeDocument(Document document);
 
     default void addDocumentIfMissing(Document document) {

core/src/main/java/de/bwaldvogel/mongo/backend/AbstractSynchronizedMongoCollection.java

@@ -19,6 +19,11 @@ public synchronized void addDocument(Document document) {
         super.addDocument(document);
     }
 
+    @Override
+    public synchronized void addDocuments(List<Document> documents) {
+        super.addDocuments(documents);
+    }
+
     @Override
     public synchronized Document findAndModify(Document query) {
         return super.findAndModify(query);

core/src/main/java/de/bwaldvogel/mongo/oplog/CollectionBackedOplog.java

@@ -3,6 +3,7 @@
 import java.util.List;
 import java.util.UUID;
 import java.util.function.Function;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import de.bwaldvogel.mongo.MongoBackend;
@@ -39,29 +40,32 @@ public void handleInsert(String namespace, List<Document> documents) {
         if (isOplogCollection(namespace)) {
             return;
         }
-        documents.stream()
+        final List<Document> oplogInsertDocuments = documents.stream()
             .map(document -> toOplogInsertDocument(namespace, document))
-            .forEach(collection::addDocument);
+            .collect(Collectors.toList());
+        collection.addDocuments(oplogInsertDocuments);
     }
 
     @Override
     public void handleUpdate(String namespace, Document selector, Document query, List<Object> modifiedIds) {
         if (isOplogCollection(namespace)) {
             return;
         }
-        modifiedIds.forEach(id ->
-            collection.addDocument(toOplogUpdateDocument(namespace, query, id))
-        );
+        final List<Document> oplogUpdateDocuments = modifiedIds.stream()
+            .map(id -> toOplogUpdateDocument(namespace, query, id))
+            .collect(Collectors.toList());
+        collection.addDocuments(oplogUpdateDocuments);
     }
 
     @Override
     public void handleDelete(String namespace, Document query, List<Object> deletedIds) {
         if (isOplogCollection(namespace)) {
             return;
         }
-        deletedIds.forEach(id ->
-            collection.addDocument(toOplogDeleteDocument(namespace, id))
-        );
+        final List<Document> oplogDeleteDocuments = deletedIds.stream()
+            .map(id -> toOplogDeleteDocument(namespace, id))
+            .collect(Collectors.toList());
+        collection.addDocuments(oplogDeleteDocuments);
     }
 
     @Override