diff --git a/persistence/dao/ceobe-operate/src/mongo/tool_link/retrieve.rs b/persistence/dao/ceobe-operate/src/mongo/tool_link/retrieve.rs index a17227bc..ef77e1a3 100644 --- a/persistence/dao/ceobe-operate/src/mongo/tool_link/retrieve.rs +++ b/persistence/dao/ceobe-operate/src/mongo/tool_link/retrieve.rs @@ -1,5 +1,5 @@ use db_ops_prelude::{ - futures::StreamExt, + futures::{StreamExt, TryStreamExt}, mongo_connection::{MongoDbCollectionTrait, MongoDbError}, mongodb::options::{CountOptions, FindOptions}, }; @@ -39,15 +39,12 @@ where .limit(paginator.limit() as i64) .build(); - let mut cursor = db + let result = db .doing(|collection| collection.find(None, find_options)) + .await? + .try_collect() .await?; - let mut result = Vec::::new(); - while let Some(doc) = cursor.next().await { - result.push(doc.map_err(MongoDbError::from)?) - } - Ok(result) }