On stable Rust, async fn cannot be used in traits. There is ongoing work that will make this possible in the future, but the easiest solution currently is to use the async-trait crate: #[async_trait] trait Readable { async fn readable(&self) -> io::Result<()>; } #[async_trait] impl Readable for Reader { async fn readable(&self) -> io::Result<()> { … Read more
Hyper 0.13 provides a body::to_bytes function for this purpose. use hyper::body; use hyper::{Body, Response}; pub async fn read_response_body(res: Response<Body>) -> Result<String, hyper::Error> { let bytes = body::to_bytes(res.into_body()).await?; Ok(String::from_utf8(bytes.to_vec()).expect(“response was not valid utf-8”)) }
Concurrent requests As of reqwest 0.10: use futures::{stream, StreamExt}; // 0.3.5 use reqwest::Client; // 0.10.6 use tokio; // 0.2.21, features = [“macros”] const CONCURRENT_REQUESTS: usize = 2; #[tokio::main] async fn main() { let client = Client::new(); let urls = vec![“https://api.ipify.org”; 2]; let bodies = stream::iter(urls) .map(|url| { let client = &client; async move { let … Read more