rx-rust 0.3.0

Reactive Programming in Rust inspired by ReactiveX https://reactivex.io/
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

use rx_rust::utils::types::RefGuard;

pub(crate) trait TestMutableHelper<T> {
    fn test_lock_ref(&self) -> RefGuard<'_, T>;
}

cfg_if::cfg_if! {
    if #[cfg(feature = "single-threaded")] {
        use std::cell::RefCell;
        impl<T> TestMutableHelper<T> for RefCell<T> {
            fn test_lock_ref(&self) -> RefGuard<'_, T> {
                self.borrow()
            }
        }
    } else {
        use std::sync::{Mutex};
        use rx_rust::utils::types::ReadOnlyMutexGuard;
        impl<T> TestMutableHelper<T> for Mutex<T> {
            fn test_lock_ref(&self) -> RefGuard<'_, T> {
                ReadOnlyMutexGuard::new(self.lock().unwrap())
            }
        }
    }
}