chaindexing 0.1.80

Index any EVM chain and query in SQL
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

use futures_core::Future;
use futures_util::future::join_all;
use std::{pin::Pin, sync::Arc};
use tokio::sync::Mutex;

type DeferredFuture<'a> = Pin<Box<dyn Future<Output = ()> + 'a + Send>>;

#[derive(Clone)]
pub struct DeferredFutures<'a> {
    futures: Arc<Mutex<Vec<DeferredFuture<'a>>>>,
}

impl<'a> Default for DeferredFutures<'a> {
    fn default() -> Self {
        Self::new()
    }
}

impl<'a> DeferredFutures<'a> {
    pub fn new() -> Self {
        Self {
            futures: Arc::new(Mutex::new(Vec::new())),
        }
    }
    pub async fn add<'b: 'a, F>(&self, future: F)
    where
        F: Future<Output = ()> + Send + 'b,
    {
        let mut futures = self.futures.lock().await;
        futures.push(Box::pin(future));
    }
    pub async fn consume(&self) {
        let mut futures = self.futures.lock().await;

        join_all(futures.iter_mut()).await;

        *futures = Vec::new();
    }
}