airlock 0.0.2

no_std async 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
28
29
30
31
32
33
34
35
36
37
38
39
40

use core::borrow::{Borrow, BorrowMut};
use std::sync::Arc;

#[derive(Debug, Clone, Default)]
pub struct Counter(Arc<()>, Arc<()>);

#[derive(Debug)]
pub struct Counted<T>(Arc<()>, T);

impl Counter {
    pub fn new() -> Self {
        Default::default()
    }

    pub fn count(&self) -> usize {
        Arc::strong_count(&self.0) - Arc::strong_count(&self.1)
    }

    pub fn add<T>(&self, value: T) -> Counted<T> {
        Counted(Arc::clone(&self.0), value)
    }
}

impl<T> Counted<T> {
    pub fn unwrap(self) -> T {
        self.1
    }
}

impl<T> Borrow<T> for Counted<T> {
    fn borrow(&self) -> &T {
        &self.1
    }
}

impl<T> BorrowMut<T> for Counted<T> {
    fn borrow_mut(&mut self) -> &mut T {
        &mut self.1
    }
}