Merge pull request #2 from Ludea/tcpstream

Use TcpStream instead of hyper connect
allan2 · Jan 10, 2024 · 52d6bc5 · 52d6bc5
2 parents 3542956 + ff0b124
commit 52d6bc5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/tonic/src/transport/server/mod.rs b/tonic/src/transport/server/mod.rs
@@ -43,7 +43,7 @@ use crate::body::BoxBody;
 use bytes::Bytes;
 use http::{Request, Response};
 use http_body::Body as _;
-use hyper::{server::accept, Body};
+use hyper::Body;
 use pin_project::pin_project;
 use std::{
     convert::Infallible,
@@ -57,6 +57,7 @@ use std::{
     time::Duration,
 };
 use tokio::io::{AsyncRead, AsyncWrite};
+use tokio::net::TcpStream;
 use tokio_stream::Stream;
 use tower::{
     layer::util::{Identity, Stack},
@@ -527,7 +528,7 @@ impl<L> Server<L> {
         let svc = self.service_builder.service(svc);
 
         let tcp = incoming::tcp_incoming(incoming, self);
-        let incoming = accept::from_stream::<_, _, crate::Error>(tcp);
+        let incoming = TcpStream::accept::from_stream::<_, _, crate::Error>(tcp);
 
         let svc = MakeSvc {
             inner: svc,