refactor(core/raw): Cleanup not used oio::WriteBuf and `oio::Chunke…

…dBytes` after refactor (#4361) * clean block Signed-off-by: Xuanwo <[email protected]> * Refactor exact buf write Signed-off-by: Xuanwo <[email protected]> * refactor multipart write Signed-off-by: Xuanwo <[email protected]> * Refactor range write Signed-off-by: Xuanwo <[email protected]> * Cleanup async body Signed-off-by: Xuanwo <[email protected]> * remove chunked bytes Signed-off-by: Xuanwo <[email protected]> * Remove write buf Signed-off-by: Xuanwo <[email protected]> * Fix exact buf Signed-off-by: Xuanwo <[email protected]> --------- Signed-off-by: Xuanwo <[email protected]>
apache · Mar 14, 2024 · 48235d5 · 48235d5
1 parent 3f8736d
commit 48235d5
Show file tree

Hide file tree

Showing 12 changed files with 68 additions and 884 deletions.
diff --git a/core/src/raw/http_util/body.rs b/core/src/raw/http_util/body.rs
@@ -35,10 +35,6 @@ pub enum AsyncBody {
     Empty,
     /// Body with bytes.
     Bytes(Bytes),
-    /// Body with chunked bytes.
-    ///
-    /// This is nearly the same with stream, but we can save an extra box.
-    ChunkedBytes(oio::ChunkedBytes),
     /// Body with stream.
     Stream(oio::Streamer),
 }

diff --git a/core/src/raw/http_util/client.rs b/core/src/raw/http_util/client.rs
@@ -118,17 +118,6 @@ impl HttpClient {
         req_builder = match body {
             AsyncBody::Empty => req_builder.body(reqwest::Body::from("")),
             AsyncBody::Bytes(bs) => req_builder.body(reqwest::Body::from(bs)),
-            AsyncBody::ChunkedBytes(bs) => {
-                #[cfg(not(target_arch = "wasm32"))]
-                {
-                    req_builder.body(reqwest::Body::wrap_stream(bs))
-                }
-                #[cfg(target_arch = "wasm32")]
-                {
-                    let bs = oio::WriteBuf::bytes(&bs, bs.len());
-                    req_builder.body(reqwest::Body::from(bs))
-                }
-            }
             AsyncBody::Stream(s) => {
                 #[cfg(not(target_arch = "wasm32"))]
                 {

diff --git a/core/src/raw/http_util/multipart.rs b/core/src/raw/http_util/multipart.rs
@@ -404,7 +404,6 @@ impl MixedPart {
                 bs.len() as u64,
                 Some(Box::new(oio::Cursor::from(bs)) as Streamer),
             ),
-            AsyncBody::ChunkedBytes(bs) => (bs.len() as u64, Some(Box::new(bs) as Streamer)),
             AsyncBody::Stream(stream) => {
                 let len = parts
                     .headers