leyline-http 0.1.5

use std::time::Instant;

use http::StatusCode;
use leyline::Session;

#[tokio::main]
async fn main() -> leyline::Result<()> {
    let url = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "https://httpbin.org/get".to_string());

    let session = Session::builder().build()?;

    let n = 50usize;
    let started = Instant::now();

    let mut handles = Vec::with_capacity(n);
    for i in 0..n {
        let session = session.clone();
        let url = url.clone();
        handles.push(tokio::spawn(async move {
            let resp = session.get(&url).await?;
            Ok::<(usize, StatusCode), leyline::Error>((i, resp.status()))
        }));
    }

    let mut ok = 0usize;
    for h in handles {
        if let Ok(Ok((_, status))) = h.await
            && !status.is_client_error()
            && !status.is_server_error()
        {
            ok += 1;
        }
    }

    let elapsed = started.elapsed();
    println!(
        "{n} concurrent requests: {ok} succeeded in {:.2?} ({:.0} req/s)",
        elapsed,
        n as f64 / elapsed.as_secs_f64()
    );
    Ok(())
}