hyper-util

Cargo.toml

@@ -62,6 +62,7 @@ regex-syntax = "0.7.4"
 url = "2.4.0"
 pin-project-lite = "0.2.13"
 http-body-util = "0.1.0"
+hyper-util = "0.1.1"
 
 [target.'cfg(unix)'.dependencies]
 rlimit = "0.10.0"
@@ -71,6 +72,5 @@ jemallocator = "0.5.0"
 assert_cmd = "2.0.2"
 axum = { version = "0.7", features = ["http2"] }
 bytes = "1.0"
-hyper-util = "0.1.1"
 lazy_static = "1.4.0"
 regex = "1.9.6"

src/client.rs

@@ -4,14 +4,14 @@ use hyper::{
     body::{Body, Incoming},
     http,
 };
+use hyper_util::rt::{TokioExecutor, TokioIo};
 use rand::prelude::*;
 use std::{pin::Pin, sync::Arc};
 use thiserror::Error;
 use tokio::net::TcpStream;
 use url::{ParseError, Url};
 
 use crate::{
-    tokiort::{TokioExecutor, TokioIo},
     url_generator::{UrlGenerator, UrlGeneratorError},
     ConnectToEntry,
 };
@@ -238,7 +238,7 @@ impl Stream {
         }
     }
     async fn handshake_http2(self) -> Result<SendRequestHttp2, ClientError> {
-        let builder = hyper::client::conn::http2::Builder::new(TokioExecutor);
+        let builder = hyper::client::conn::http2::Builder::new(TokioExecutor::new());
 
         match self {
             Stream::Tcp(stream) => {

src/main.rs

@@ -19,7 +19,6 @@ mod histogram;
 mod monitor;
 mod printer;
 mod timescale;
-mod tokiort;
 mod url_generator;
 
 #[cfg(unix)]