retry_future 0.4.0

Retry futures mechanism
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use retry_future::{LinearRetryStrategy, RetryFuture, RetryPolicy};
use std::time::Duration;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let text = RetryFuture::new(
        || async {
            Ok::<_, RetryPolicy>(reqwest::get("http://localhost:8085").await?.text().await?)
        },
        LinearRetryStrategy::default()
            .max_attempts(10)
            .delay_between_retries(Duration::from_millis(100)),
    )
    .await?;

    eprintln!("text = {:#?}", text);

    Ok(())
}