blob-indexer 0.6.1

Blob indexer for the Blobscan explorer
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

use std::{future::Future, time::Duration};

use tracing::debug;

/// Retries an async operation that returns `Ok(None)` when the resource is not yet available.
/// Useful for handling race conditions where data is expected but may not be immediately queryable.
pub async fn retry_on_none<F, Fut, T, E>(
    fetch: F,
    max_attempts: u32,
    retry_delay: Duration,
) -> Result<Option<T>, E>
where
    F: Fn() -> Fut,
    Fut: Future<Output = Result<Option<T>, E>>,
{
    for attempt in 1..=max_attempts {
        match fetch().await? {
            Some(value) => return Ok(Some(value)),
            None if attempt < max_attempts => {
                debug!(
                    attempt,
                    "Resource not yet available, retrying in {}ms…",
                    retry_delay.as_millis()
                );

                tokio::time::sleep(retry_delay).await;
            }
            None => break,
        }
    }

    Ok(None)
}