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

use std::sync::Arc;
use tokio::sync::Mutex;

#[derive(Clone, Debug)]
pub struct NodeTask {
    subtasks: Arc<Mutex<Vec<tokio::task::JoinHandle<()>>>>,
}

impl Default for NodeTask {
    fn default() -> Self {
        Self::new()
    }
}

impl NodeTask {
    pub fn new() -> Self {
        NodeTask {
            subtasks: Arc::new(Mutex::new(Vec::new())),
        }
    }
    pub async fn add_subtask(&self, task: tokio::task::JoinHandle<()>) {
        let mut subtasks = self.subtasks.lock().await;
        subtasks.push(task);
    }
    pub async fn stop(&self) {
        let subtasks = self.subtasks.lock().await;
        for subtask in subtasks.iter() {
            subtask.abort();
        }
    }
}