lo_ 0.3.1

A modern Rust utility library delivering modularity, performance & extras ported from JavaScript Lodash
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

#[cfg(feature = "async_retry")]
use std::time::Duration;
#[cfg(feature = "async_retry")]
use tokio::time::sleep;

/// Retry an async operation with exponential backoff.
///
/// Requires the `async_retry` feature.
///
/// # Examples
/// ```rust
/// # use std::time::Duration;
/// # async fn do_work() -> Result<u8, &'static str> { Err("fail") }
/// # #[tokio::main]
/// # async fn main() {
/// use lo_::async_retry;
///
/// let result = async_retry(3, Duration::from_millis(100), || do_work()).await;
/// # }
/// ```
///
/// # Features
/// This function is only available when the `async_retry` feature is enabled.
#[cfg(feature = "async_retry")]
pub async fn async_retry<T, E, Fut, F>(times: usize, delay: Duration, mut op: F) -> Result<T, E>
where
    F: FnMut() -> Fut,
    Fut: std::future::Future<Output = Result<T, E>>,
{
    let mut attempts = 0;
    let mut current_delay = delay;

    loop {
        match op().await {
            Ok(res) => return Ok(res),
            Err(e) if attempts + 1 >= times => return Err(e),
            Err(_) => {
                attempts += 1;
                sleep(current_delay).await;
                current_delay *= 2; // Exponential backoff
            }
        }
    }
}