liminal-server 0.24.5

Standalone server for the liminal messaging bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

//! Cancellation retains the registered subscription even after its index is retired.

use super::{UdpError, recovery::Acknowledgements};
use std::sync::Arc;

#[derive(Clone, Debug)]
pub struct LinkCancellation(Arc<Acknowledgements>);

impl LinkCancellation {
    pub(super) const fn new(signal: Arc<Acknowledgements>) -> Self {
        Self(signal)
    }

    pub(crate) fn cancel(&self) -> Result<(), UdpError> {
        self.0.cancel()
    }
}