diff --git a/integration/ducks/Cargo.toml b/integration/ducks/Cargo.toml index ab7a081fd..09686a871 100644 --- a/integration/ducks/Cargo.toml +++ b/integration/ducks/Cargo.toml @@ -11,7 +11,7 @@ publish = false anyhow = "1.0" bytes = { workspace = true } entropy = "0.4" -hyper = { version = "0.14", features = ["server"] } +hyper = { version = "0.14", features = ["server", "backports", "deprecated"] } once_cell = { workspace = true } shared = { path = "../shared" } sketches-ddsketch = "0.3" diff --git a/integration/ducks/src/main.rs b/integration/ducks/src/main.rs index 849bb5bf7..a93063525 100644 --- a/integration/ducks/src/main.rs +++ b/integration/ducks/src/main.rs @@ -16,7 +16,7 @@ use anyhow::Context; use bytes::BytesMut; use hyper::{ - body, + body::HttpBody, server::conn::{AddrIncoming, AddrStream}, service::{make_service_fn, service_fn}, Body, Method, Request, StatusCode, @@ -127,7 +127,7 @@ impl From<&SocketCounters> for SocketMetrics { #[tracing::instrument(level = "trace")] async fn http_req_handler(req: Request) -> Result, hyper::Error> { let (parts, body) = req.into_parts(); - let body = body::to_bytes(body).await?; + let body = body.collect().await?.to_bytes(); { let metric = HTTP_COUNTERS.get().expect("HTTP_COUNTERS not initialized");