Fix hyper example

Author: aumetra

opentelemetry-otlp/examples/basic-otlp-http/Cargo.toml

@@ -8,7 +8,7 @@ publish = false
 [features]
 default = ["reqwest"]
 reqwest = ["opentelemetry-otlp/reqwest-client"]
-hyper = ["dep:async-trait", "dep:http", "dep:hyper", "dep:opentelemetry-http", "dep:bytes"]
+hyper = ["dep:async-trait", "dep:http", "dep:http-body-util", "dep:hyper", "dep:hyper-util", "dep:opentelemetry-http", "dep:bytes"]
 
 
 [dependencies]
@@ -23,7 +23,9 @@ opentelemetry-semantic-conventions = { path = "../../../opentelemetry-semantic-c
 async-trait = { workspace = true, optional = true }
 bytes = { workspace = true, optional = true }
 http = { workspace = true, optional = true }
+http-body-util = { workspace = true, optional = true  }
 hyper = { workspace = true, features = ["client"], optional = true }
+hyper-util = { workspace = true, features = ["client-legacy"], optional = true }
 tokio = { workspace = true, features = ["full"] }
 tracing = { workspace = true, features = ["std"]}
 tracing-core = { workspace = true }

opentelemetry-otlp/examples/basic-otlp-http/src/hyper.rs

@@ -1,20 +1,24 @@
 use async_trait::async_trait;
 use bytes::Bytes;
 use http::{Request, Response};
-use hyper::{
-    client::{connect::Connect, HttpConnector},
-    Body, Client,
+use http_body_util::{BodyExt, Full};
+use hyper_util::{
+    client::legacy::{
+        connect::{Connect, HttpConnector},
+        Client,
+    },
+    rt::TokioExecutor,
 };
 use opentelemetry_http::{HttpClient, HttpError, ResponseExt};
 
 pub struct HyperClient<C> {
-    inner: hyper::Client<C>,
+    inner: hyper_util::client::legacy::Client<C, Full<Bytes>>,
 }
 
 impl Default for HyperClient<HttpConnector> {
     fn default() -> Self {
         Self {
-            inner: Client::new(),
+            inner: Client::builder(TokioExecutor::new()).build_http(),
         }
     }
 }
@@ -30,15 +34,15 @@ impl<C> std::fmt::Debug for HyperClient<C> {
 #[async_trait]
 impl<C: Connect + Clone + Send + Sync + 'static> HttpClient for HyperClient<C> {
     async fn send(&self, request: Request<Vec<u8>>) -> Result<Response<Bytes>, HttpError> {
-        let request = request.map(Body::from);
+        let request = request.map(|body| Full::new(Bytes::from(body)));
 
         let (parts, body) = self
             .inner
             .request(request)
             .await?
             .error_for_status()?
             .into_parts();
-        let body = hyper::body::to_bytes(body).await?;
+        let body = body.collect().await?.to_bytes();
 
         Ok(Response::from_parts(parts, body))
     }