diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2023-12-24 14:14:29 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-12-24 14:14:29 +0100 |
commit | e1bfb29868cf49b949560bc3328ea824400a1319 (patch) | |
tree | 492f63317c9bf4b8885e2ecf9bc4723826b4da42 /test_util/src/servers/grpc.rs | |
parent | 92b2e28c6491f339124ec5851173ac0aaef93908 (diff) |
refactor: use hyper 1.0 in grpc test server (#21584)
Ref https://github.com/denoland/deno/issues/21578
Diffstat (limited to 'test_util/src/servers/grpc.rs')
-rw-r--r-- | test_util/src/servers/grpc.rs | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/test_util/src/servers/grpc.rs b/test_util/src/servers/grpc.rs index b957d4c92..08d297a4c 100644 --- a/test_util/src/servers/grpc.rs +++ b/test_util/src/servers/grpc.rs @@ -1,8 +1,9 @@ // Copyright 2018-2023 the Deno authors. All rights reserved. MIT license. use futures::StreamExt; -use hyper::header::HeaderValue; -use hyper::http; +use h2_04 as h2; +use hyper1::header::HeaderName; +use hyper1::header::HeaderValue; use rustls_tokio_stream::TlsStream; use tokio::net::TcpStream; use tokio::task::LocalSet; @@ -47,7 +48,7 @@ pub async fn h2_grpc_server(h2_grpc_port: u16, h2s_grpc_port: u16) { } async fn handle_request( - mut request: http::Request<h2::RecvStream>, + mut request: hyper1::Request<h2::RecvStream>, mut respond: h2::server::SendResponse<bytes::Bytes>, ) -> Result<(), anyhow::Error> { let body = request.body_mut(); @@ -58,17 +59,17 @@ pub async fn h2_grpc_server(h2_grpc_port: u16, h2s_grpc_port: u16) { let maybe_recv_trailers = body.trailers().await?; - let response = http::Response::new(()); + let response = hyper1::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 = http::HeaderMap::new(); + let mut trailers = hyper1::HeaderMap::new(); trailers.insert( - http::HeaderName::from_static("abc"), + HeaderName::from_static("abc"), HeaderValue::from_static("def"), ); trailers.insert( - http::HeaderName::from_static("opr"), + HeaderName::from_static("opr"), HeaderValue::from_static("stv"), ); if let Some(recv_trailers) = maybe_recv_trailers { |