rx-rust 1.0.1

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 crate::disposable::Disposable;
use educe::Educe;

#[derive(Educe)]
#[educe(Debug, Clone)]
pub struct OptionDisposal<D>(Option<D>);

impl<D> OptionDisposal<D> {
    pub fn some(disposal: D) -> Self {
        Self(Some(disposal))
    }

    pub fn none() -> Self {
        Self(None)
    }
}

impl<D: Disposable> Disposable for OptionDisposal<D> {
    fn dispose(self) {
        if let Some(disposal) = self.0 {
            Disposable::dispose(disposal)
        }
    }
}