Fix

Author: tyranron

juniper_hyper/src/lib.rs

@@ -116,8 +116,8 @@ where
         .await
         .map_err(GraphQLRequestError::BodyHyper)?;
 
-    let input = String::from_utf8(chunk.to_bytes().iter().cloned().collect())
-        .map_err(GraphQLRequestError::BodyUtf8)?;
+    let input =
+        String::from_utf8(chunk.to_bytes().into()).map_err(GraphQLRequestError::BodyUtf8)?;
 
     serde_json::from_str::<GraphQLBatchRequest<S>>(&input)
         .map_err(GraphQLRequestError::BodyJSONError)
@@ -135,8 +135,8 @@ where
         .await
         .map_err(GraphQLRequestError::BodyHyper)?;
 
-    let query = String::from_utf8(chunk.to_bytes().iter().cloned().collect())
-        .map_err(GraphQLRequestError::BodyUtf8)?;
+    let query =
+        String::from_utf8(chunk.to_bytes().into()).map_err(GraphQLRequestError::BodyUtf8)?;
 
     Ok(GraphQLBatchRequest::Single(GraphQLRequest::new(
         query, None, None,

juniper_warp/Cargo.toml

@@ -47,7 +47,6 @@ http-body-util = "0.1.2"
 [dev-dependencies]
 async-stream = "0.3"
 env_logger = "0.11"
-futures = "0.3.22"
 http-body-util = "0.1.2"
 itertools = "0.14"
 juniper = { version = "0.16", path = "../juniper", features = ["expose-test-schema"] }

juniper_warp/tests/http_test_suite.rs

@@ -2,7 +2,6 @@
 
 #![expect(unused_crate_dependencies, reason = "integration tests")]
 
-use futures::TryStreamExt as _;
 use http_body_util::BodyExt as _;
 use itertools::Itertools as _;
 use juniper::{
@@ -123,14 +122,8 @@ async fn into_test_response(resp: reply::Response) -> TestResponse {
         })
         .unwrap_or_default();
 
-    let body = String::from_utf8(
-        body.into_data_stream()
-            .map_ok(|bytes| bytes.to_vec())
-            .try_concat()
-            .await
-            .unwrap(),
-    )
-    .unwrap_or_else(|e| panic!("not UTF-8 body: {e}"));
+    let body = String::from_utf8(body.collect().await.unwrap().to_bytes().into())
+        .unwrap_or_else(|e| panic!("not UTF-8 body: {e}"));
 
     TestResponse {
         status_code,