potential 3.0.1

PubSub lib with sync and async API
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
41
42
43
44
45
46
47
48
49
50
51
52

use crate::{Pub, Sub, TryPopError};
use log::trace;
use std::{sync::Arc, task::Waker};

impl<T> Pub<T> {
    pub(crate) fn notify(&mut self) {
        loop {
            match self.wakers.try_pop() {
                Ok(waker) => {
                    trace!("waking");
                    waker.wake_by_ref();
                }
                Err(TryPopError::Empty) => {
                    // no pending wakers
                    trace!("no more wakers");
                    break;
                }
                Err(TryPopError::Finished) => {
                    trace!("no more subs");
                    break;
                }
            }
        }
    }
}
impl<T> Sub<T> {
    pub(crate) fn add_waker(&mut self, waker: &Waker) -> bool {
        self.wakers.push(Notify::from(waker.clone()))
    }
}

#[derive(Debug, Clone)]
pub struct Notify(Arc<Waker>);
impl std::ops::Deref for Notify {
    type Target = Waker;

    fn deref(&self) -> &Self::Target {
        self.0.as_ref()
    }
}
impl From<Waker> for Notify {
    fn from(value: Waker) -> Self {
        Self(value.into())
    }
}
impl Drop for Notify {
    fn drop(&mut self) {
        if let Some(waker) = Arc::get_mut(&mut self.0) {
            waker.wake_by_ref();
        }
    }
}