context-async 1.0.0

context handle async future timeout or cancel
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

use std::time;
use context_async::{Error, Timer, With};

/// In this file, we send a HTTP GET request to https://www.example.com.
/// We use context to handle slow network, and kill the request after 3 seconds.

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // give only 3 seconds to finish the request
    let timer = Timer::with_timeout(time::Duration::from_secs(3));

    let url = "https://www.example.com";

    let response = reqwest::Client::new()
        .get(url)
        .send()
        .with(timer.clone()) // add our timer to request future.
        .await;

    #[allow(unreachable_patterns)]
    match response {
        Ok(Ok(response)) => println!("successfully request: {:?}", response),
        Ok(Err(err)) => println!("request error from reqwest: {:?}", err),
        Err(err) => match err {
            Error::ContextTimeout => println!("request timeout: {}", err),
            Error::ContextCancelled => println!("request cancelled: {}", err),
            _ => unimplemented!(),
        }
    }

    Ok(())
}