use std::time::Instant; use futures::stream::FuturesUnordered;use futures::AsyncReadExt as _;use http_client::AsyncBody;use http_client::HttpClient;use reqwest_client::ReqwestClient;use smol::stream::StreamExt; fn main() { let app = gpui::App::new(); app.run(|cx| { cx.spawn(|cx| async move { let client = ReqwestClient::new(); let start = Instant::now(); let requests = [ client.get("https://www.google.com/", AsyncBody::empty(), true), client.get("https://zed.dev/", AsyncBody::empty(), true), client.get("https://docs.rs/", AsyncBody::empty(), true), ]; let mut requests = requests.into_iter().collect::<FuturesUnordered<_>>(); while let Some(response) = requests.next().await { let mut body = String::new(); response .unwrap() .into_body() .read_to_string(&mut body) .await .unwrap(); println!("{}", &body.len()); } println!("{:?}", start.elapsed()); cx.update(|cx| { cx.quit(); }) .ok(); }) .detach(); })}
use std::time::Instant;
use futures::stream::FuturesUnordered;
use futures::AsyncReadExt as _;
use http_client::AsyncBody;
use http_client::HttpClient;
use reqwest_client::ReqwestClient;
use smol::stream::StreamExt;
fn main() {
let app = gpui::App::new();
app.run(|cx| {
cx.spawn(|cx| async move {
let client = ReqwestClient::new();
let start = Instant::now();
let requests = [
client.get("https://www.google.com/", AsyncBody::empty(), true),
client.get("https://zed.dev/", AsyncBody::empty(), true),
client.get("https://docs.rs/", AsyncBody::empty(), true),
];
let mut requests = requests.into_iter().collect::<FuturesUnordered<_>>();
while let Some(response) = requests.next().await {
let mut body = String::new();
response
.unwrap()
.into_body()
.read_to_string(&mut body)
.await
.unwrap();
println!("{}", &body.len());
}
println!("{:?}", start.elapsed());
cx.update(|cx| {
cx.quit();
})
.ok();
})
.detach();
})
}