alkhttp 0.5.0

HTTP interface for the alk stack: serves HTTP/1.1 + HTTP/2 on standard ALPNs (with WebSocket upgrade carrying the channels protocol) and hosts the HTTP-backed call-protocol adapters
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

//! COV-12/FWD-12: `SharedHttpClient::config()` reflects the config the
//! running clients were built from, and a `reload` swaps the config
//! together with both clients in one atomic store — after a reload,
//! `config()` shows the new generation and the old one is unreachable
//! for every late reader (FWD-12's atomicity assertion).

use std::time::Duration;

use alkhttp::client::{HttpClientConfig, SharedHttpClient};

#[test]
fn config_accessor_tracks_a_reloaded_config() {
    let initial = HttpClientConfig {
        retry_after_ceiling: Duration::from_secs(11),
        ..HttpClientConfig::default()
    };
    let http = SharedHttpClient::new(initial).expect("initial client builds");
    assert_eq!(
        http.config().retry_after_ceiling,
        Duration::from_secs(11),
        "config() starts as the config the client was built from"
    );
    let reloaded = HttpClientConfig {
        retry_after_ceiling: Duration::from_secs(22),
        ..HttpClientConfig::default()
    };
    futures::executor::block_on(http.reload(reloaded)).expect("reload succeeds");
    assert_eq!(
        http.config().retry_after_ceiling,
        Duration::from_secs(22),
        "config() reflects the reloaded generation, not the initial one (FWD-12)"
    );
}