diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2023-12-27 17:59:57 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-12-27 11:59:57 -0500 |
commit | c2414db1f68d27db8ca6f192f0ff877f1394164c (patch) | |
tree | 528da9796f400557204bfdb8e4d44d64173036ce /test_util/src/servers/grpc.rs | |
parent | 33acd437f52b418a8413a302dd8902abad2eabec (diff) |
refactor: simplify hyper, http, h2 deps (#21715)
Main change is that:
- "hyper" has been renamed to "hyper_v014" to signal that it's legacy
- "hyper1" has been renamed to "hyper" and should be the default
Diffstat (limited to 'test_util/src/servers/grpc.rs')
-rw-r--r-- | test_util/src/servers/grpc.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/test_util/src/servers/grpc.rs b/test_util/src/servers/grpc.rs index 096f8c85f..dfbf160f6 100644 --- a/test_util/src/servers/grpc.rs +++ b/test_util/src/servers/grpc.rs @@ -2,8 +2,8 @@ use futures::StreamExt; use h2; -use hyper1::header::HeaderName; -use hyper1::header::HeaderValue; +use hyper::header::HeaderName; +use hyper::header::HeaderValue; use rustls_tokio_stream::TlsStream; use tokio::net::TcpStream; use tokio::task::LocalSet; @@ -48,7 +48,7 @@ pub async fn h2_grpc_server(h2_grpc_port: u16, h2s_grpc_port: u16) { } async fn handle_request( - mut request: hyper1::Request<h2::RecvStream>, + mut request: hyper::Request<h2::RecvStream>, mut respond: h2::server::SendResponse<bytes::Bytes>, ) -> Result<(), anyhow::Error> { let body = request.body_mut(); @@ -59,11 +59,11 @@ pub async fn h2_grpc_server(h2_grpc_port: u16, h2s_grpc_port: u16) { let maybe_recv_trailers = body.trailers().await?; - let response = hyper1::Response::new(()); + let response = hyper::Response::new(()); let mut send = respond.send_response(response, false)?; send.send_data(bytes::Bytes::from_static(b"hello "), false)?; send.send_data(bytes::Bytes::from_static(b"world\n"), false)?; - let mut trailers = hyper1::HeaderMap::new(); + let mut trailers = hyper::HeaderMap::new(); trailers.insert( HeaderName::from_static("abc"), HeaderValue::from_static("def"), |