| 167 | /// Return [QueryResult]s from a multi-query operation |
| 168 | #[instrument(level = "trace")] |
| 169 | pub fn fetch( |
| 170 | &self, |
| 171 | statement: &Statement, |
| 172 | ) -> Pin<Box<dyn Stream<Item = Result<QueryResult, DbErr>> + Send>> { |
| 173 | match self.query_all(statement.clone()) { |
| 174 | Ok(v) => Box::pin(futures_util::stream::iter(v.into_iter().map(Ok))), |
| 175 | Err(e) => Box::pin(futures_util::stream::iter(Some(Err(e)).into_iter())), |
| 176 | } |
| 177 | } |
| 178 | |
| 179 | /// Create a statement block of SQL statements that execute together. |
| 180 | /// |