Update to return a Stream<Sting,BsonValue> to the aggregate method

Signed-off-by: Otavio Santana <[email protected]>

Author: otaviojava

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

@@ -189,12 +189,13 @@ public long delete(String collectionName, Bson filter) {
      * @return the number of documents deleted.
      * @throws NullPointerException when filter or collectionName is null
      */
-    public Stream<List<jakarta.nosql.document.Document>> aggregate(String collectionName, List<Bson> pipeline) {
+    public Stream<Map<String, BsonValue>> aggregate(String collectionName, List<Bson> pipeline) {
         Objects.requireNonNull(pipeline, "filter is required");
         Objects.requireNonNull(collectionName, "collectionName is required");
         MongoCollection<Document> collection = mongoDatabase.getCollection(collectionName);
         AggregateIterable<Document> aggregate = collection.aggregate(pipeline);
-        return stream(aggregate.spliterator(), false).map(MongoDBUtils::of);
+        return stream(aggregate.spliterator(), false)
+                .map(Document::toBsonDocument);
     }
 
     /**