arangodb
diff --git a/‎pom.xml
Lines changed: 1 addition & 1 deletion b/‎pom.xml
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/com/arangodb/springframework/core/template/ArangoExtCursor.java
Lines changed: 24 additions & 0 deletions b/‎src/main/java/com/arangodb/springframework/core/template/ArangoExtCursor.java
Lines changed: 24 additions & 0 deletions
diff --git a/‎src/main/java/com/arangodb/springframework/core/template/ArangoTemplate.java
Lines changed: 9 additions & 4 deletions b/‎src/main/java/com/arangodb/springframework/core/template/ArangoTemplate.java
Lines changed: 9 additions & 4 deletions
@@ -275,7 +275,7 @@
 			<dependency>
 				<groupId>com.arangodb</groupId>
 				<artifactId>arangodb-java-driver</artifactId>
-				<version>7.2.0-SNAPSHOT</version>
+				<version>7.1.0</version>
 			</dependency>
 		</dependencies>
 	</dependencyManagement>
 
@@ -26,11 +26,16 @@
 import com.arangodb.entity.CursorWarning;
 import com.arangodb.springframework.core.mapping.event.AfterLoadEvent;
 import com.arangodb.springframework.core.mapping.event.ArangoMappingEvent;
+import org.slf4j.LoggerFactory;
 import org.springframework.context.ApplicationEventPublisher;
 
 import java.io.IOException;
+import java.util.ArrayList;
 import java.util.Collection;
+import java.util.List;
 import java.util.function.Function;
+import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
 
 /**
  * @author Mark Vollmary
@@ -78,6 +83,20 @@ public boolean isCached() {
         return delegate.isCached();
     }
 
+    @Override
+    public List<T> asListRemaining() {
+        final List<T> remaining = new ArrayList<>();
+        while (hasNext()) {
+            remaining.add(next());
+        }
+        try {
+            close();
+        } catch (final Exception e) {
+            LoggerFactory.getLogger(ArangoExtCursor.class).warn("Could not close cursor: ", e);
+        }
+        return remaining;
+    }
+
     @Override
     public boolean isPotentialDirtyRead() {
         return delegate.isPotentialDirtyRead();
@@ -93,6 +112,11 @@ public ArangoIterator<T> iterator() {
         return this;
     }
 
+    @Override
+    public Stream<T> stream() {
+        return StreamSupport.stream(spliterator(), false);
+    }
+
     @Override
     public void close() throws IOException {
         delegate.close();
 
@@ -304,7 +304,7 @@ public <T> MultiDocumentEntity<DocumentDeleteEntity<T>> deleteAll(
 
         MultiDocumentEntity<DocumentDeleteEntity<T>> result;
         try {
-            result = _collection(entityClass).deleteDocuments(values, options, entityClass);
+            result = _collection(entityClass).deleteDocuments(toList(values), options, entityClass);
         } catch (final ArangoDBException e) {
             throw DataAccessUtils.translateIfNecessary(e, exceptionTranslator);
         }
@@ -355,7 +355,7 @@ public <T> MultiDocumentEntity<DocumentUpdateEntity<T>> updateAll(
 
         MultiDocumentEntity<DocumentUpdateEntity<T>> result;
         try {
-            result = _collection(entityClass).updateDocuments(values, options, entityClass);
+            result = _collection(entityClass).updateDocuments(toList(values), options, entityClass);
         } catch (final ArangoDBException e) {
             throw DataAccessUtils.translateIfNecessary(e, exceptionTranslator);
         }
@@ -408,7 +408,7 @@ public <T> MultiDocumentEntity<DocumentUpdateEntity<T>> replaceAll(
 
         MultiDocumentEntity<DocumentUpdateEntity<T>> result;
         try {
-            result = _collection(entityClass).replaceDocuments(values, options, entityClass);
+            result = _collection(entityClass).replaceDocuments(toList(values), options, entityClass);
         } catch (final ArangoDBException e) {
             throw DataAccessUtils.translateIfNecessary(e, exceptionTranslator);
         }
@@ -501,7 +501,7 @@ public <T> MultiDocumentEntity<DocumentCreateEntity<T>> insertAll(
 
         MultiDocumentEntity<DocumentCreateEntity<T>> result;
         try {
-            result = _collection(entityClass).insertDocuments(values, options, entityClass);
+            result = _collection(entityClass).insertDocuments(toList(values), options, entityClass);
         } catch (final ArangoDBException e) {
             throw DataAccessUtils.translateIfNecessary(e, exceptionTranslator);
         }
@@ -783,4 +783,9 @@ public ResolverFactory getResolverFactory() {
         return this.resolverFactory;
     }
 
+    private <T> List<T> toList(Iterable<T> it) {
+        ArrayList<T> l = new ArrayList<>();
+        it.forEach(l::add);
+        return l;
+    }
 }