(self, pool: &'c Pool)
| 20 | #[inline] |
| 21 | async fn execute(self, pool: &'c Pool) -> Result<Self::ExecuteOutput, Error> { |
| 22 | // response is owned so the connection goes back to the pool before it's awaited. |
| 23 | let affected = { |
| 24 | let conn = pool.get().await?; |
| 25 | self.query(&conn).await.map(RowAffected::from) |
| 26 | }; |
| 27 | affected?.await |
| 28 | } |
| 29 | |
| 30 | #[inline] |
| 31 | async fn query(self, pool: &'c Pool) -> Result<Self::QueryOutput, Error> { |
| 32 | let conn = pool.get().await?; |
| 33 | self.query(&conn).await |
| 34 | } |
no test coverage detected