support async read body for client

tardis/Cargo.toml

@@ -190,6 +190,7 @@ poem-grpc = { version = "0.4", optional = true }
 reqwest = { version = "0.12", features = [
   "json",
   "multipart",
+  "stream"
 ], optional = true }
 
 # Websocket Client

tardis/src/web/web_client.rs

@@ -3,6 +3,7 @@ use std::time::Duration;
 
 use reqwest::{Client, IntoUrl, Method, RequestBuilder, Response};
 use serde::Deserialize;
+use tokio::io::AsyncRead;
 use tracing::{error, info, trace};
 
 use crate::basic::error::TardisError;
@@ -33,6 +34,19 @@ impl TardisRequestBody for () {
     }
 }
 
+/// Async Read for [`TardisWebClient`],
+pub struct Read<R>(R);
+
+impl<R> TardisRequestBody for Read<R>
+where
+    R: AsyncRead + Send + Sync + Unpin + 'static,
+{
+    fn apply_on(self, builder: RequestBuilder) -> RequestBuilder {
+        let stream = tokio_util::io::ReaderStream::new(self.0);
+        builder.body(reqwest::Body::wrap_stream(stream))
+    }
+}
+
 /// Plain text body for [`TardisWebClient`],
 pub struct PlainText<T>(T);
 
@@ -253,7 +267,7 @@ impl TardisWebClient {
         self.to_json::<T>(code, headers, response).await
     }
 
-    async fn request<K, V>(
+    pub async fn request<K, V>(
         &self,
         method: Method,
         url: impl IntoUrl,