strev 0.5.0

Event-driven pub/sub messaging library with compile-time ack safety
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

#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum Outcome {
    Acked(sealed::AckToken),
    Nacked(sealed::AckToken),
}

impl Outcome {
    pub(crate) fn acked() -> Self {
        Self::Acked(sealed::AckToken(()))
    }

    pub(crate) fn nacked() -> Self {
        Self::Nacked(sealed::AckToken(()))
    }

    pub fn is_acked(self) -> bool {
        matches!(self, Self::Acked(_))
    }

    pub fn is_nacked(self) -> bool {
        matches!(self, Self::Nacked(_))
    }
}

mod sealed {
    #[derive(Clone, Copy, Debug, PartialEq, Eq)]
    pub struct AckToken(pub(super) ());
}