Fix code

Author: tyranron

juniper_warp/Cargo.toml

@@ -38,22 +38,20 @@ juniper_graphql_ws = { version = "0.4.0", path = "../juniper_graphql_ws", featur
 log = { version = "0.4", optional = true }
 serde_json = "1.0.18"
 tokio = { version = "1.0", features = ["rt"] }
-warp = { version = "0.4.0", default-features = false }
-
-# Fixes for `minimal-versions` check.
-# TODO: Try remove on upgrade of `warp` crate.
-headers = "0.3.8"
+warp = "0.4"
 
 [dev-dependencies]
 async-stream = "0.3"
 env_logger = "0.11"
 futures = "0.3.22"
+http-body-util = "0.1"
 itertools = "0.14"
 juniper = { version = "0.16", path = "../juniper", features = ["expose-test-schema"] }
 log = "0.4"
 percent-encoding = "2.1"
 tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }
 url = "2.0"
+warp = { version = "0.4", features = ["test"] }
 
 [lints.clippy]
 allow_attributes = "warn"

juniper_warp/src/lib.rs

@@ -6,11 +6,6 @@
     expect(unused_crate_dependencies, reason = "examples and integration tests")
 )]
 
-// TODO: Try remove on upgrade of `warp` crate.
-mod for_minimal_versions_check_only {
-    use headers as _;
-}
-
 mod response;
 #[cfg(feature = "subscriptions")]
 pub mod subscriptions;

juniper_warp/tests/http_test_suite.rs

@@ -3,6 +3,7 @@
 #![expect(unused_crate_dependencies, reason = "integration tests")]
 
 use futures::TryStreamExt as _;
+use http_body_util::BodyExt as _;
 use itertools::Itertools as _;
 use juniper::{
     EmptyMutation, EmptySubscription, RootNode,
@@ -123,7 +124,8 @@ async fn into_test_response(resp: reply::Response) -> TestResponse {
         .unwrap_or_default();
 
     let body = String::from_utf8(
-        body.map_ok(|bytes| bytes.to_vec())
+        body.into_data_stream()
+            .map_ok(|bytes| bytes.to_vec())
             .try_concat()
             .await
             .unwrap(),