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
37
38
39
40
41
42
43
44

use std::time::Duration;

use reqx::advanced::TimeoutPhase;
use reqx::prelude::{Client, Error, RetryPolicy};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-overrides")
        .request_timeout(Duration::from_secs(2))
        .total_timeout(Duration::from_secs(8))
        .retry_policy(RetryPolicy::standard().max_attempts(3))
        .build()?;

    let fast = client
        .get("/delay/1")
        .timeout(Duration::from_millis(300))
        .retry_policy(RetryPolicy::disabled())
        .send()
        .await;

    match fast {
        Ok(response) => {
            println!("unexpected success: status={}", response.status());
        }
        Err(Error::Timeout { phase, .. }) if phase == TimeoutPhase::Transport => {
            println!("request-level timeout works: phase={phase}");
        }
        Err(other) => {
            println!("request failed with: {other}");
        }
    }

    let stable = client
        .get("/get")
        .timeout(Duration::from_secs(2))
        .total_timeout(Duration::from_secs(3))
        .retry_policy(RetryPolicy::standard().max_attempts(2))
        .send()
        .await?;

    println!("GET /get => status={}", stable.status());
    Ok(())
}