feat(volo-http): support convert linkedbytes to body without copy

Author: Ggiggle

Cargo.lock

@@ -152,3 +152,6 @@ codegen-units = 1
 panic = 'unwind'
 incremental = false
 overflow-checks = false
+
+[patch.crates-io]
+linkedbytes = { git = "https://github.com/Ggiggle/linkedbytes.git", branch = "feat/into_iter" }

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "volo-http"
-version = "0.3.1"
+version = "0.3.2"
 edition.workspace = true
 homepage.workspace = true
 repository.workspace = true
@@ -22,6 +22,7 @@ maintenance = { status = "actively-developed" }
 volo = { version = "0.10", path = "../volo" }
 
 ahash.workspace = true
+async-stream.workspace = true
 bytes.workspace = true
 faststr.workspace = true
 futures.workspace = true
@@ -32,6 +33,7 @@ http-body-util.workspace = true
 hyper.workspace = true
 hyper-util = { workspace = true, features = ["tokio"] }
 itoa.workspace = true
+linkedbytes.workspace = true
 metainfo.workspace = true
 mime.workspace = true
 motore.workspace = true
@@ -55,14 +57,14 @@ url.workspace = true
 # =====optional=====
 
 # server optional
-ipnet = { workspace = true, optional = true } # client ip
-matchit = { workspace = true, optional = true } # route matching
-memchr = { workspace = true, optional = true } # sse
+ipnet = { workspace = true, optional = true }      # client ip
+matchit = { workspace = true, optional = true }    # route matching
+memchr = { workspace = true, optional = true }     # sse
 scopeguard = { workspace = true, optional = true } # defer
 
 # client optional
-async-broadcast = { workspace = true, optional = true } # service discover
-chrono = { workspace = true, optional = true } # stat
+async-broadcast = { workspace = true, optional = true }  # service discover
+chrono = { workspace = true, optional = true }           # stat
 hickory-resolver = { workspace = true, optional = true } # dns resolver
 mime_guess = { workspace = true, optional = true }
 
@@ -100,24 +102,37 @@ default-client = ["client", "json"]
 default-server = ["server", "query", "form", "json", "multipart"]
 
 full = [
-    "client", "server", # core
-    "query", "form", "json", # serde
-    "tls", # https
-    "cookie", "multipart", "ws", # exts
+    "client",
+    "server",    # core
+    "query",
+    "form",
+    "json",      # serde
+    "tls",       # https
+    "cookie",
+    "multipart",
+    "ws",        # exts
 ]
 
 http1 = ["hyper/http1", "hyper-util/http1"]
 
 client = [
-    "http1", "hyper/client",
-    "dep:async-broadcast", "dep:chrono", "dep:hickory-resolver",
+    "http1",
+    "hyper/client",
+    "dep:async-broadcast",
+    "dep:chrono",
+    "dep:hickory-resolver",
 ] # client core
 server = [
-    "http1", "hyper-util/server",
-    "dep:ipnet", "dep:matchit", "dep:memchr", "dep:scopeguard", "dep:mime_guess",
+    "http1",
+    "hyper-util/server",
+    "dep:ipnet",
+    "dep:matchit",
+    "dep:memchr",
+    "dep:scopeguard",
+    "dep:mime_guess",
 ] # server core
 
-__serde = ["dep:serde"] # a private feature for enabling `serde` by `serde_xxx`
+__serde = ["dep:serde"]                           # a private feature for enabling `serde` by `serde_xxx`
 query = ["__serde", "dep:serde_urlencoded"]
 form = ["__serde", "dep:serde_urlencoded"]
 json = ["__serde", "dep:sonic-rs"]

volo-http/Cargo.toml

@@ -16,6 +16,7 @@ use futures_util::stream::Stream;
 use http_body::{Frame, SizeHint};
 use http_body_util::{combinators::BoxBody, BodyExt, Full, StreamBody};
 use hyper::body::Incoming;
+use linkedbytes::{LinkedBytes, Node};
 use pin_project::pin_project;
 #[cfg(feature = "json")]
 use serde::de::DeserializeOwned;
@@ -332,3 +333,43 @@ impl From<String> for Body {
         }
     }
 }
+
+impl From<LinkedBytes> for Body {
+    fn from(value: LinkedBytes) -> Self {
+        let stream = async_stream::stream! {
+            for node in value.into_iter_list() {
+                match node {
+                    Node::Bytes(bytes) => {
+                        yield Ok(Frame::data(bytes));
+                    }
+                    Node::BytesMut(bytes) => {
+                        yield Ok(Frame::data(bytes.freeze()));
+                    }
+                    Node::FastStr(faststr) => {
+                        yield Ok(Frame::data(faststr.into_bytes()));
+                    }
+                }
+            }
+        };
+        Self {
+            repr: BodyRepr::Stream(StreamBody::new(Box::pin(stream))),
+        }
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[tokio::test]
+    async fn test_from_linked_bytes() {
+        let mut bytes = LinkedBytes::new();
+        bytes.insert(Bytes::from_static(b"Hello,"));
+        bytes.insert_faststr(FastStr::new(" world!"));
+        let body = Body::from(bytes);
+        assert_eq!(
+            body.into_bytes().await.unwrap(),
+            Bytes::from_static(b"Hello, world!")
+        );
+    }
+}