1
- use bson:: { doc, DateTime } ;
1
+ use bson:: { doc, DateTime , Document } ;
2
2
use mongodb:: { Client , Collection } ;
3
3
use serde:: { Deserialize , Serialize } ;
4
+ use futures:: stream:: TryStreamExt ;
4
5
5
6
#[ tokio:: main]
6
7
async fn main ( ) -> mongodb:: error:: Result < ( ) > {
@@ -42,8 +43,7 @@ async fn main() -> mongodb::error::Result<()> {
42
43
43
44
let mut results = my_coll. aggregate ( age_pipeline) . await ?;
44
45
while let Some ( result) = results. try_next ( ) . await ? {
45
- let doc = mongodb:: bson:: from_document ( result) ?;
46
- println ! ( "* {:?}" , doc) ;
46
+ println ! ( "* {:?}" , result) ;
47
47
}
48
48
// end-age-agg
49
49
@@ -57,8 +57,7 @@ async fn main() -> mongodb::error::Result<()> {
57
57
58
58
let mut results = my_coll. aggregate ( last_active_pipeline) . await ?;
59
59
while let Some ( result) = results. try_next ( ) . await ? {
60
- let doc = mongodb:: bson:: from_document ( result) ?;
61
- println ! ( "* {:?}" , doc) ;
60
+ println ! ( "* {:?}" , result) ;
62
61
}
63
62
// end-lastactive-agg
64
63
@@ -72,8 +71,7 @@ async fn main() -> mongodb::error::Result<()> {
72
71
73
72
let mut results = my_coll. aggregate ( popularity_pipeline) . await ?;
74
73
while let Some ( result) = results. try_next ( ) . await ? {
75
- let doc = mongodb:: bson:: from_document ( result) ?;
76
- println ! ( "* {:?}" , doc) ;
74
+ println ! ( "* {:?}" , result) ;
77
75
}
78
76
// end-popular-agg
79
77
0 commit comments