reqx 0.1.35

Rust HTTP transport client for API SDK libraries with retry, timeout, idempotency, proxy, and pluggable TLS backends
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

use std::time::Duration;

use reqx::prelude::{Client, RetryPolicy};
use tokio::time::Instant;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-concurrency")
        .request_timeout(Duration::from_secs(5))
        .retry_policy(RetryPolicy::disabled())
        .max_in_flight(1)
        .build()?;

    let started = Instant::now();
    let mut handles = Vec::new();

    for idx in 0..3 {
        let client = client.clone();
        handles.push(tokio::spawn(async move {
            let result = client.get("/delay/1").send().await;
            (idx, result.map(|response| response.status().as_u16()))
        }));
    }

    for handle in handles {
        let (idx, result) = handle.await?;
        match result {
            Ok(status) => println!("request-{idx} status={status}"),
            Err(error) => println!("request-{idx} error={error}"),
        }
    }

    println!("elapsed_ms={}", started.elapsed().as_millis());
    Ok(())
}