debot-utils 1.0.34

Utility functions for dex trading
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 tokio::time::sleep;
use tokio::time::Duration;

pub async fn retry_loop<F, Fut, T, E>(
    mut operation: F,
    retries: usize,
    delay: Duration,
    label: &str,
) -> Result<T, E>
where
    F: FnMut() -> Fut,
    Fut: std::future::Future<Output = Result<T, E>>,
    E: std::fmt::Debug,
{
    for attempt in 0..=retries {
        match operation().await {
            Ok(result) => return Ok(result),
            Err(e) => {
                log::warn!(
                    "Attempt {}/{} failed during {}: {:?}",
                    attempt + 1,
                    retries + 1,
                    label,
                    e
                );
                sleep(delay).await;
            }
        }
    }

    operation().await
}