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

use crate::{
    disposable::Disposable,
    safe_lock_option_disposable,
    utils::types::{Mutable, Shared},
};

impl<D> Disposable for Shared<Mutable<Option<D>>>
where
    D: Disposable,
{
    fn dispose(self) {
        safe_lock_option_disposable!(dispose: self);
    }
}

#[cfg(feature = "futures")]
impl Disposable for futures::stream::AbortHandle {
    fn dispose(self) {
        self.abort();
    }
}