From c2414db1f68d27db8ca6f192f0ff877f1394164c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bartek=20Iwa=C5=84czuk?= Date: Wed, 27 Dec 2023 17:59:57 +0100 Subject: 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 --- test_util/src/servers/hyper_utils.rs | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) (limited to 'test_util/src/servers/hyper_utils.rs') diff --git a/test_util/src/servers/hyper_utils.rs b/test_util/src/servers/hyper_utils.rs index b8e9472a4..9f61f022f 100644 --- a/test_util/src/servers/hyper_utils.rs +++ b/test_util/src/servers/hyper_utils.rs @@ -9,7 +9,6 @@ use http; use http::Request; use http::Response; use http_body_util::combinators::UnsyncBoxBody; -use hyper1 as hyper; use hyper_util::rt::TokioIo; use std::convert::Infallible; use std::io; @@ -46,7 +45,7 @@ where loop { let (stream, _) = listener.accept().await?; let io = TokioIo::new(stream); - deno_unsync::spawn(hyper1_serve_connection( + deno_unsync::spawn(hyper_serve_connection( io, handler, options.error_msg, @@ -76,7 +75,7 @@ pub async fn run_server_with_acceptor<'a, A, F, S>( while let Some(result) = acceptor.next().await { let stream = result?; let io = TokioIo::new(stream); - deno_unsync::spawn(hyper1_serve_connection( + deno_unsync::spawn(hyper_serve_connection( io, handler, error_msg, kind, )); } @@ -89,7 +88,7 @@ pub async fn run_server_with_acceptor<'a, A, F, S>( } } -async fn hyper1_serve_connection( +async fn hyper_serve_connection( io: I, handler: F, error_msg: &'static str, @@ -99,7 +98,7 @@ async fn hyper1_serve_connection( F: Fn(Request) -> S + Copy + 'static, S: Future + 'static, { - let service = hyper1::service::service_fn(handler); + let service = hyper::service::service_fn(handler); let result: Result<(), anyhow::Error> = match kind { ServerKind::Auto => { @@ -111,7 +110,7 @@ async fn hyper1_serve_connection( .map_err(|e| anyhow::anyhow!("{}", e)) } ServerKind::OnlyHttp1 => { - let builder = hyper1::server::conn::http1::Builder::new(); + let builder = hyper::server::conn::http1::Builder::new(); builder .serve_connection(io, service) .await @@ -119,7 +118,7 @@ async fn hyper1_serve_connection( } ServerKind::OnlyHttp2 => { let builder = - hyper1::server::conn::http2::Builder::new(DenoUnsyncExecutor); + hyper::server::conn::http2::Builder::new(DenoUnsyncExecutor); builder .serve_connection(io, service) .await -- cgit v1.2.3