concuring 0.1.0

A synchronous, concurrent HTTP client library for Rust that uses io_uring.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use color_eyre::Result;
mod concuring;
mod request;
use concuring::Concuring;
use request::RequestBuilder;

fn main() -> Result<()> {
    // Initialize tracing subscriber
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("concuring=debug")),
        )
        .init();

    let mut client = Concuring::<8>::new()?;

    let request = RequestBuilder::get("http://127.0.0.1:7777/")
        .unwrap()
        .append_header("Connection", "close")
        .unwrap()
        .build_without_body();

    client
        .try_submit(1, request)
        .expect("has space for 1 request");
    client.wait().expect("should get 1 resp at least");
    assert!(client.wait().is_none());
    while let Some(resp) = client.finished_responses.pop_front() {
        println!("Request {} finalized", resp.0);
        let resp = resp.1.expect("success");
        eprintln!("got resp with body {}", resp.body().len());
        // println!("{}", String::from_utf8_lossy(resp.body()))
    }

    Ok(())
}