bitrouter-providers 0.33.0

BitRouter provider adapters — HTTP client, auth, streaming
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

//! Shared utilities for provider implementations.

/// Guard that aborts background refresh tasks on drop.
///
/// Used by provider registries to manage background listeners
/// that watch for upstream capability changes.
pub struct RefreshGuard {
    handles: Vec<tokio::task::JoinHandle<()>>,
}

impl RefreshGuard {
    /// Build a guard from a list of already-spawned task handles.
    pub fn from_handles(handles: Vec<tokio::task::JoinHandle<()>>) -> Self {
        Self { handles }
    }
}

impl Drop for RefreshGuard {
    fn drop(&mut self) {
        for handle in &self.handles {
            handle.abort();
        }
    }
}