pub fn aggregate_with_session(
        &self,
        pipeline: impl IntoIterator<Item = Document>,
        options: impl Into<Option<AggregateOptions>>,
        session: &mut ClientSession,
    ) -> Result<SessionCursor<Document>> {
        let pipeline: Vec<Document> = pipeline.into_iter().collect();
        RUNTIME
            .block_on(self.async_collection.aggregate_with_session(
                pipeline,
                options.into(),
                &mut session.async_client_session,
            ))
            .map(SessionCursor::new)
    }
/// Runs an aggregation operation using the provided `ClientSession`.
///
/// See the documentation [here](https://docs.mongodb.com/manual/aggregation/) for more
/// information on aggregations.
Runs an aggregation operation using the provided `ClientSession`.
See the documentation [here] for more
information on aggregations.
Runs an aggregation operation using the provided ` ClientSession ` . See the documentation [ here ] for more information on aggregations .
pub fn aggregate_with_session(
        &self,
        pipeline: impl IntoIterator<Item = Document>,
        options: impl Into<Option<AggregateOptions>>,
        session: &mut ClientSession,
    ) -> Result<SessionCursor<Document>> {
        let pipeline: Vec<Document> = pipeline.into_iter().collect();
        RUNTIME
            .block_on(self.async_collection.aggregate_with_session(
                pipeline,
                options.into(),
                &mut session.async_client_session,
            ))
            .map(SessionCursor::new)
    }
pub fn aggregate_with_session ( & self , pipeline : impl IntoIterator < Item = Document > , options : impl Into < Option < AggregateOptions > > , session : & mut ClientSession , ) -> Result < SessionCursor < Document > > { let pipeline : Vec < Document > = pipeline . into_iter ( ) . collect ( ) ; RUNTIME . block_on ( self . async_collection . aggregate_with_session ( pipeline , options . into ( ) , & mut session . async_client_session , ) ) . map ( SessionCursor :: new ) }
Runs an aggregation operation using the provided `ClientSession`.
Runs an aggregation operation using the provided ` ClientSession ` .
&self
pipeline
impl IntoIterator<Item = Document>
options
impl Into<Option<AggregateOptions>>
session
&mut ClientSession
&self
pipeline
impl IntoIterator<Item = Document>
options
impl Into<Option<AggregateOptions>>
session
&mut ClientSession