tycho-util 0.3.7

Shared utilities for node components.
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

use std::sync::Arc;
use std::time::Duration;

use futures_util::Future;
use tokio::task::AbortHandle;

pub fn spawn_metrics_loop<T, F, FR>(context: &Arc<T>, interval: Duration, f: F) -> AbortHandle
where
    T: Send + Sync + 'static,
    F: Fn(Arc<T>) -> FR + Send + Sync + 'static,
    FR: Future<Output = ()> + Send + Sync + 'static,
{
    let context = Arc::downgrade(context);
    tokio::spawn(async move {
        let mut interval = tokio::time::interval(interval);
        loop {
            interval.tick().await;
            if let Some(context) = context.upgrade() {
                f(context).await;
            } else {
                break;
            }
        }
    })
    .abort_handle()
}