fetch 0.13.0

HTTP client with resilience, observability, and Tokio runtime support.
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

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Integration tests for request timeout behavior.

use std::time::Duration;

use fetch::fake::FakeDeps;
use fetch::{HttpClient, Recovery, RecoveryInfo};
use http_extensions::FakeHandler;
use ohno::Labeled;
use tick::ClockControl;

#[cfg_attr(miri, ignore)]
#[tokio::test]
async fn response_timeout() {
    let handler = FakeHandler::never_completes();
    let clock = ClockControl::new().auto_advance_timers(true).to_clock();
    let client = HttpClient::builder_fake(handler, FakeDeps { clock }).minimal_pipeline().build();

    let err = client
        .get("https://example.com")
        .response_timeout(Duration::from_secs(10))
        .fetch()
        .await
        .unwrap_err();

    assert_eq!(err.recovery(), RecoveryInfo::retry());
    assert_eq!(err.label(), "response_timeout");
}