Add proxy Body::collect_bytes for easier unit tests (#1445)

* Expose `Body::collect` for easier unit tests Avoids people having to pull in `http_body_util` for the `BodyExt` Signed-off-by: clux <[email protected]> * avoid opaque Collect and Collected and await + into_bytes instead Signed-off-by: clux <[email protected]> * Update kube-client/src/client/body.rs Co-authored-by: Matei David <[email protected]> Signed-off-by: Eirik A <[email protected]> * Update kube-client/src/client/body.rs Co-authored-by: Matei David <[email protected]> Signed-off-by: Eirik A <[email protected]> --------- Signed-off-by: clux <[email protected]> Signed-off-by: Eirik A <[email protected]> Co-authored-by: Matei David <[email protected]>
kube-rs · Apr 2, 2024 · db7878e · db7878e
1 parent 067b68d
commit db7878e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/kube-client/src/client/body.rs b/kube-client/src/client/body.rs
@@ -44,6 +44,11 @@ impl Body {
         Body::new(Kind::Wrap(body.map_err(Into::into).boxed_unsync()))
     }
 
+    /// Collect all the data frames and trailers of the request body
+    pub async fn collect_bytes(self) -> Result<Bytes, crate::Error> {
+        Ok(self.collect().await?.to_bytes())
+    }
+
     pub(crate) fn into_data_stream(
         self,
     ) -> impl Stream<Item = Result<<Self as HttpBody>::Data, <Self as HttpBody>::Error>> {