xenith-sync 0.1.0

State sync engine for xenith — push, read, and resolve across chains
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

use xenith_core::{ChainId, StateKey};

/// Handle to a running subscription polling loop.
///
/// Dropping or calling [`cancel`][SubscriptionHandle::cancel] stops the loop.
pub struct SubscriptionHandle {
    pub key: StateKey,
    pub source_chain: ChainId,
    abort_handle: tokio::task::AbortHandle,
}

impl SubscriptionHandle {
    pub(crate) fn new(
        key: StateKey,
        source_chain: ChainId,
        abort_handle: tokio::task::AbortHandle,
    ) -> Self {
        Self {
            key,
            source_chain,
            abort_handle,
        }
    }

    /// Stop the subscription polling loop.
    pub fn cancel(self) {
        self.abort_handle.abort();
    }
}