refactor client body (#1464)

* remove unnecessary heap pin Signed-off-by: tottoto <[email protected]> * use Poll::map_err method to convert error type Signed-off-by: tottoto <[email protected]> --------- Signed-off-by: tottoto <[email protected]>
kube-rs · Apr 9, 2024 · bf62f56 · bf62f56
1 parent 2fb575c
commit bf62f56
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/kube-client/src/client/body.rs b/kube-client/src/client/body.rs
@@ -1,8 +1,8 @@
 use std::{
     error::Error as StdError,
     fmt,
-    pin::Pin,
-    task::{ready, Context, Poll},
+    pin::{pin, Pin},
+    task::{Context, Poll},
 };
 
 use bytes::Bytes;
@@ -87,10 +87,7 @@ impl HttpBody for Body {
     ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> {
         match &mut self.kind {
             Kind::Once(val) => Poll::Ready(val.take().map(|bytes| Ok(Frame::data(bytes)))),
-            Kind::Wrap(body) => Poll::Ready(
-                ready!(Pin::new(body).poll_frame(cx))
-                    .map(|opt_chunk| opt_chunk.map_err(crate::Error::Service)),
-            ),
+            Kind::Wrap(body) => pin!(body).poll_frame(cx).map_err(crate::Error::Service),
         }
     }