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
45
46

use std::time::Duration;

#[cfg(any(
    feature = "blocking-tls-rustls-ring",
    feature = "blocking-tls-rustls-aws-lc-rs",
    feature = "blocking-tls-native"
))]
fn main() -> Result<(), Box<dyn std::error::Error>> {
    use std::io::Cursor;

    use reqx::blocking::Client;
    use reqx::prelude::RetryPolicy;

    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-blocking-stream")
        .request_timeout(Duration::from_secs(5))
        .retry_policy(RetryPolicy::standard().max_attempts(2))
        .build()?;

    let mut writer = Vec::new();
    let copied = client
        .get("/stream/5")
        .download_to_writer_limited(&mut writer, 1024 * 1024)?;
    println!("download copied bytes={copied}");

    let reader_payload = Cursor::new(b"hello from blocking reader".to_vec());
    let upload_status = client
        .post("/post")
        .idempotency_key("blocking-upload-reader-001")?
        .body_reader_with_length(reader_payload, 26)?
        .send()?
        .status();
    println!("upload status={upload_status}");

    Ok(())
}

#[cfg(not(any(
    feature = "blocking-tls-rustls-ring",
    feature = "blocking-tls-rustls-aws-lc-rs",
    feature = "blocking-tls-native"
)))]
fn main() {
    let _ = Duration::from_secs(1);
    eprintln!("enable a `blocking-tls-*` feature to run this example");
}