Method fetch

tank-core/src/executor.rs:63–74

Executes a query and streams the resulting rows, ignoring affected counts.

(
        &'s mut self,
        query: impl AsQuery<Self::Driver> + 's,
    )

    /// Executes a query and streams the resulting rows, ignoring affected counts.
    fn fetch<'s>(
        &'s mut self,
        query: impl AsQuery<Self::Driver> + 's,
    ) -> impl Stream<Item = Result<Row>> + Send {
        self.run(query).filter_map(|v| async move {
            match v {
                Ok(QueryResult::Row(v)) => Some(Ok(v)),
                Err(e) => Some(Err(e)),
                _ => None,
            }
        })
    }

    /// Executes a query and returns the total number of affected rows.
    fn execute<'s>(