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
47
48
49
50

use std::time::Duration;

use reqx::prelude::{Client, RetryPolicy};
use serde::Serialize;
use serde_json::Value;

#[derive(Debug, Serialize)]
struct SearchQuery<'a> {
    term: &'a str,
    page: u32,
}

#[derive(Debug, Serialize)]
struct LoginForm<'a> {
    username: &'a str,
    password: &'a str,
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::builder("https://postman-echo.com")
        .client_name("reqx-example-request-helpers")
        .request_timeout(Duration::from_secs(3))
        .retry_policy(RetryPolicy::disabled())
        .try_default_header("x-sdk-version", "1.0.0")?
        .build()?;

    let get_response: Value = client
        .get("/get")
        .query(&SearchQuery {
            term: "reqx",
            page: 2,
        })?
        .try_header("x-request-id", "req-001")?
        .send_json()
        .await?;
    println!("GET /get args={:?}", get_response.get("args"));

    let form_response: Value = client
        .post("/post")
        .form(&LoginForm {
            username: "alice",
            password: "secret",
        })?
        .send_json()
        .await?;
    println!("POST /post form={:?}", form_response.get("form"));

    Ok(())
}