wasm-bus 1.1.0

Invocation bus for web assembly modules
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use cooked_waker::WakeRef;
use std::sync::atomic::*;

#[derive(Debug, Default)]
pub struct RuntimeWaker {
    count: AtomicUsize,
}

impl RuntimeWaker {
    #[allow(dead_code)]
    pub fn get(&self) -> usize {
        self.count.load(Ordering::SeqCst)
    }
}

impl WakeRef for RuntimeWaker {
    fn wake_by_ref(&self) {
        let _prev = self.count.fetch_add(1, Ordering::SeqCst);
    }
}