chore(channel): Remove duplicate heap pin (#1798)

tottoto · web-flow · commit 539d6f7c082f · 2024-07-15T06:21:57.000Z
diff --git a/tonic/src/transport/channel/mod.rs b/tonic/src/transport/channel/mod.rs
@@ -157,7 +157,7 @@ impl Channel {
 
         let svc = Connection::lazy(connector, endpoint);
         let (svc, worker) = Buffer::pair(Either::A(svc), buffer_size);
-        executor.execute(Box::pin(worker));
+        executor.execute(worker);
 
         Channel { svc }
     }
@@ -176,7 +176,7 @@ impl Channel {
             .await
             .map_err(super::Error::from_source)?;
         let (svc, worker) = Buffer::pair(Either::A(svc), buffer_size);
-        executor.execute(Box::pin(worker));
+        executor.execute(worker);
 
         Ok(Channel { svc })
     }

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ impl Channel {`
`157`	`157`
`158`	`158`	`let svc = Connection::lazy(connector, endpoint);`
`159`	`159`	`let (svc, worker) = Buffer::pair(Either::A(svc), buffer_size);`
`160`		`- executor.execute(Box::pin(worker));`
	`160`	`+ executor.execute(worker);`
`161`	`161`
`162`	`162`	`Channel { svc }`
`163`	`163`	`}`
`@@ -176,7 +176,7 @@ impl Channel {`
`176`	`176`	`.await`
`177`	`177`	`.map_err(super::Error::from_source)?;`
`178`	`178`	`let (svc, worker) = Buffer::pair(Either::A(svc), buffer_size);`
`179`		`- executor.execute(Box::pin(worker));`
	`179`	`+ executor.execute(worker);`
`180`	`180`
`181`	`181`	`Ok(Channel { svc })`
`182`	`182`	`}`