buckn/derive_http
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed awc thing

Browse Source
This commit is contained in:
Nathan Buck
2025-07-14 23:06:29 -04:00
parent 5b3641d930
commit a096885f02
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/lib.rs
View File

@ -74,14 +74,14 @@ pub fn derive_http_get_request(input: TokenStream) -> TokenStream {
} }
} }
let response = actix_web::rt::System::new() let response = rt::System::new()
.block_on(async { .block_on(async {
request.send() request.send()
.await .await
.map_err(|e| std::io::Error::new(std::io::ErrorKind::Other, e.to_string())) .map_err(|e| std::io::Error::new(std::io::ErrorKind::Other, e.to_string()))
})?; })?;
let body_bytes = actix_web::rt::System::new() let body_bytes = rt::System::new()
.block_on(async { .block_on(async {
response.body() response.body()
.await .await
@ -148,7 +148,7 @@ pub fn http_response(_attr: TokenStream, item: TokenStream) -> TokenStream {
where where
Self: serde::de::DeserializeOwned + Sized + Send, Self: serde::de::DeserializeOwned + Sized + Send,
{ {
async fn receive(mut resp: actix_web::ClientResponse) -> Result<Self, Box<dyn std::error::Error>> { async fn receive(mut resp: awc::ClientResponse) -> Result<Self, Box<dyn std::error::Error>> {
let parsed = resp.json::<Self>().await?; let parsed = resp.json::<Self>().await?;
Ok(parsed) Ok(parsed)
} }
@ -178,7 +178,7 @@ pub fn http_response(_attr: TokenStream, item: TokenStream) -> TokenStream {
where where
Self: Sized + Send, Self: Sized + Send,
{ {
async fn receive(mut resp: actix_web::ClientResponse) -> Result<Self, Box<dyn std::error::Error>> { async fn receive(mut resp: awc::ClientResponse) -> Result<Self, Box<dyn std::error::Error>> {
let body = resp.body().await?; // Bytes, sized! let body = resp.body().await?; // Bytes, sized!
#(#variant_arms)* #(#variant_arms)*
Err(Box::new(std::io::Error::new( Err(Box::new(std::io::Error::new(