(self, cli: &'c Client)
| 61 | Ok(RowStreamOwned::from(stream)) |
| 62 | } |
| 63 | } |
| 64 | |
| 65 | // use the new type to prepare and execute a statement. |
| 66 | let row_affected = PrepareAndExecute { |
| 67 | stmt: "SELECT 1", |
| 68 | types: &[], |
| 69 | } |
| 70 | .execute(&cli) |
| 71 | .await?; |
| 72 | assert_eq!(row_affected, 1); |
| 73 | |
| 74 | // use the new type to prepare and query a statement |
| 75 | let rows = PrepareAndExecute { |