(
send: &mut hyper::client::conn::http1::SendRequest<String>,
req: http::Request<String>,
)
| 1656 | } |
| 1657 | |
| 1658 | async fn send_request_with( |
| 1659 | send: &mut hyper::client::conn::http1::SendRequest<String>, |
| 1660 | req: http::Request<String>, |
| 1661 | ) -> Result<http::Response<String>> { |
| 1662 | let response = send |
| 1663 | .send_request(req) |
| 1664 | .await |
| 1665 | .context("error sending request")?; |
| 1666 | |
| 1667 | let (parts, body) = response.into_parts(); |
| 1668 | |
| 1669 | let body = body.collect().await.context("failed to read body")?; |
| 1670 | assert!(body.trailers().is_none()); |
| 1671 | let body = std::str::from_utf8(&body.to_bytes())?.to_string(); |
| 1672 | |
| 1673 | Ok(http::Response::from_parts(parts, body)) |
| 1674 | } |
| 1675 | |
| 1676 | async fn start_requests( |
| 1677 | &self, |
nothing calls this directly
no test coverage detected