reqres 1.0.0

A pure Rust async HTTP client library based on Tokio with HTTP/2, connection pooling, proxy, cookie, compression, benchmarks, and comprehensive tests
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use reqres::Client;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== reqres v0.4.0 HTTP/2 Client Demo ===\n");

    // 默认客户端会启用 HTTP/2
    let client = Client::new()?;

    // 测试 HTTP/2 请求
    println!("Sending HTTP/2 GET request to httpbin.org (supports HTTP/2)...");
    match client.get("https://httpbin.org/get").await {
        Ok(response) => {
            println!("✓ HTTP/2 request successful!");
            println!("  Status: {} {}", response.status(), response.status_text);
            println!("  Version: {}", response.version);

            // 检查是否使用了 HTTP/2
            if response.version == "HTTP/2.0" {
                println!("  ✓ Using HTTP/2 protocol!");
            } else {
                println!("  ⚠ Using HTTP/1.1 (server might not support HTTP/2)");
            }

            println!("\n  Response headers:");
            for (key, value) in &response.headers {
                println!("    {}: {}", key, value);
            }

            // 显示响应体预览
            if let Ok(text) = response.text() {
                let preview = if text.len() > 500 {
                    &text[..500]
                } else {
                    &text
                };
                println!("\n  Body preview:\n{}", preview);
            }
        }
        Err(e) => {
            eprintln!("✗ HTTP/2 request failed: {}", e);
        }
    }

    println!("\n{}\n", &"=".repeat(50));

    // 测试 HTTP/2 POST 请求
    println!("Sending HTTP/2 POST request...");
    let json_data = serde_json::json!({
        "test": "HTTP/2",
        "version": "0.3.0",
        "features": ["Multiplexing", "Header Compression", "Server Push"]
    });

    let request = reqres::Request::post("https://httpbin.org/post")
        .json(&json_data)?
        .build()?;

    match client.request(request).await {
        Ok(response) => {
            println!("✓ HTTP/2 POST request successful!");
            println!("  Status: {} {}", response.status(), response.status_text);
            println!("  Version: {}", response.version);

            if response.version == "HTTP/2.0" {
                println!("  ✓ Using HTTP/2 protocol!");
            }

            if let Ok(text) = response.text() {
                let preview = if text.len() > 500 {
                    &text[..500]
                } else {
                    &text
                };
                println!("\n  Body preview:\n{}", preview);
            }
        }
        Err(e) => {
            eprintln!("✗ HTTP/2 POST request failed: {}", e);
        }
    }

    println!("\n{}\n", &"=".repeat(50));

    // 测试禁用 HTTP/2
    println!("Testing HTTP/1.1 only (HTTP/2 disabled)...");
    let client_h1_only = Client::builder()
        .http1_only()
        .build()?;

    match client_h1_only.get("https://httpbin.org/get").await {
        Ok(response) => {
            println!("✓ HTTP/1.1 only request successful!");
            println!("  Status: {} {}", response.status(), response.status_text);
            println!("  Version: {}", response.version);
            println!("  ✓ Forcefully using HTTP/1.1");
        }
        Err(e) => {
            eprintln!("✗ HTTP/1.1 only request failed: {}", e);
        }
    }

    println!("\n=== Demo completed ===");
    Ok(())
}