fixes mongodb

Author: otaviojava

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

@@ -17,10 +17,10 @@
 
 
 import com.mongodb.client.model.Filters;
-import org.bson.conversions.Bson;
 import jakarta.nosql.TypeReference;
 import jakarta.nosql.document.Document;
 import jakarta.nosql.document.DocumentCondition;
+import org.bson.conversions.Bson;
 import org.jnosql.diana.driver.ValueUtil;
 
 import java.util.List;

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

@@ -32,8 +32,8 @@
 import org.jnosql.diana.document.Documents;
 
 import java.time.Duration;
-import java.util.List;
 import java.util.Objects;
+import java.util.stream.Stream;
 import java.util.stream.StreamSupport;
 
 import static java.util.stream.Collectors.toList;
@@ -131,9 +131,8 @@ public void delete(DocumentDeleteQuery query) {
         collection.deleteMany(mongoDBQuery);
     }
 
-
     @Override
-    public List<DocumentEntity> select(DocumentQuery query) {
+    public Stream<DocumentEntity> select(DocumentQuery query) {
         Objects.requireNonNull(query, "query is required");
         String collectionName = query.getDocumentCollection();
         MongoCollection<Document> collection = mongoDatabase.getCollection(collectionName);
@@ -152,7 +151,7 @@ public List<DocumentEntity> select(DocumentQuery query) {
         query.getSorts().stream().map(this::getSort).forEach(documents::sort);
 
         return stream(documents.spliterator(), false).map(MongoDBUtils::of)
-                .map(ds -> DocumentEntity.of(collectionName, ds)).collect(toList());
+                .map(ds -> DocumentEntity.of(collectionName, ds));
 
     }
 

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

@@ -40,6 +40,7 @@
 import java.util.Objects;
 import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.function.Consumer;
+import java.util.stream.Stream;
 
 import static java.util.Objects.requireNonNull;
 import static org.jnosql.diana.mongodb.document.MongoDBUtils.ID_FIELD;
@@ -141,7 +142,7 @@ public void delete(DocumentDeleteQuery query, Consumer<Void> callBack)
     }
 
     @Override
-    public void select(DocumentQuery query, Consumer<List<DocumentEntity>> callBack)
+    public void select(DocumentQuery query, Consumer<Stream<DocumentEntity>> callBack)
             throws ExecuteAsyncQueryException, UnsupportedOperationException {
 
         requireNonNull(query, "query is required");
@@ -163,7 +164,7 @@ public void select(DocumentQuery query, Consumer<List<DocumentEntity>> callBack)
 
         query.getSorts().stream().map(this::getSort).forEach(result::sort);
         Block<Document> documentBlock = d -> entities.add(createEntity(collectionName, d));
-        SingleResultCallback<Void> voidSingleResultCallback = (v, e) -> callBack.accept(entities);
+        SingleResultCallback<Void> voidSingleResultCallback = (v, e) -> callBack.accept(entities.stream());
         result.forEach(documentBlock, voidSingleResultCallback);
     }
 

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

@@ -14,10 +14,10 @@
  */
 package org.jnosql.diana.mongodb.document;
 
-import org.bson.Document;
-import org.bson.types.Binary;
 import jakarta.nosql.Value;
 import jakarta.nosql.document.DocumentEntity;
+import org.bson.Document;
+import org.bson.types.Binary;
 import org.jnosql.diana.driver.ValueUtil;
 
 import java.util.ArrayList;

mongodb-driver/src/test/java/org/jnosql/diana/mongodb/document/MongoDBDocumentCollectionManagerAsyncTest.java

@@ -35,10 +35,10 @@
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
 
-import static org.awaitility.Awaitility.await;
-import static org.hamcrest.Matchers.notNullValue;
 import static jakarta.nosql.document.DocumentDeleteQuery.delete;
 import static jakarta.nosql.document.DocumentQuery.select;
+import static org.awaitility.Awaitility.await;
+import static org.hamcrest.Matchers.notNullValue;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertThrows;

mongodb-driver/src/test/java/org/jnosql/diana/mongodb/document/MongoDBDocumentCollectionManagerTest.java

@@ -40,13 +40,13 @@
 import java.util.stream.Collectors;
 import java.util.stream.StreamSupport;
 
+import static jakarta.nosql.document.DocumentDeleteQuery.delete;
+import static jakarta.nosql.document.DocumentQuery.select;
 import static java.util.Arrays.asList;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.contains;
 import static org.hamcrest.Matchers.containsInAnyOrder;
 import static org.hamcrest.Matchers.not;
-import static jakarta.nosql.document.DocumentDeleteQuery.delete;
-import static jakarta.nosql.document.DocumentQuery.select;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;