2 files changed, 8 insertions, 34 deletions
diff --git a/test_util/src/lib.rs b/test_util/src/lib.rs
index c4789621f..555ba5271 100644
--- a/test_util/src/lib.rs
+++ b/test_util/src/lib.rs
@@ -11,10 +11,8 @@ use regex::Regex;
 use serde::Serialize;
 use std::collections::HashMap;
 use std::env;
-use std::io;
 use std::io::Write;
 use std::path::PathBuf;
-use std::pin::Pin;
 use std::process::Child;
 use std::process::Command;
 use std::process::Output;
@@ -22,8 +20,6 @@ use std::process::Stdio;
 use std::result::Result;
 use std::sync::Mutex;
 use std::sync::MutexGuard;
-use std::task::Context;
-use std::task::Poll;
 use tokio::net::TcpStream;
 use url::Url;
 
@@ -201,29 +197,6 @@ async fn get_tcp_listener_stream(
   futures::stream::select_all(listeners)
 }
 
-/// Taken from example in https://github.com/ctz/hyper-rustls/blob/a02ef72a227dcdf102f86e905baa7415c992e8b3/examples/server.rs
-struct HyperAcceptor<'a> {
-  acceptor: Pin<
-    Box<dyn Stream<Item = io::Result<rustls_tokio_stream::TlsStream>> + 'a>,
-  >,
-}
-
-impl hyper::server::accept::Accept for HyperAcceptor<'_> {
-  type Conn = rustls_tokio_stream::TlsStream;
-  type Error = io::Error;
-
-  fn poll_accept(
-    mut self: Pin<&mut Self>,
-    cx: &mut Context,
-  ) -> Poll<Option<Result<Self::Conn, Self::Error>>> {
-    Pin::new(&mut self.acceptor).poll_next(cx)
-  }
-}
-
-#[allow(clippy::non_send_fields_in_send_ty)]
-// SAFETY: unsafe trait must have unsafe implementation
-unsafe impl std::marker::Send for HyperAcceptor<'_> {}
-
 #[derive(Default)]
 struct HttpServerCount {
   count: usize,
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 {