xrpc-rs 0.3.0

async RPC library optimized for shared memory communication
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

use std::sync::Weak;
use std::time::Duration;

/// Spawns a background task that runs periodically while the owner exists.
pub fn spawn_weak_loop<T: Send + Sync + 'static>(
    owner: Weak<T>,
    interval: Duration,
    mut action: impl FnMut(&T) + Send + 'static,
) {
    tokio::spawn(async move {
        let mut timer = tokio::time::interval(interval);

        // Immediately, the first tick completes to wait for the first interval.
        timer.tick().await;

        loop {
            timer.tick().await;

            if let Some(strong) = owner.upgrade() {
                action(&strong);
            } else {
                // Owner dropped, stop the loop
                break;
            }
        }
    });
}