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
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use crate::disposable::Disposable;
use educe::Educe;

/// A disposal that calls the `dispose` method of a `Disposable` when dropped.
#[derive(Educe)]
#[educe(Debug)]
pub struct BoundDropDisposal<T>(Option<T>)
where
    T: Disposable;

impl<T> BoundDropDisposal<T>
where
    T: Disposable,
{
    pub fn new(disposal: T) -> Self {
        Self(Some(disposal))
    }
}

impl<T> Disposable for BoundDropDisposal<T>
where
    T: Disposable,
{
    fn dispose(self) {
        // drop self to call the dispose
    }
}

impl<T> Drop for BoundDropDisposal<T>
where
    T: Disposable,
{
    fn drop(&mut self) {
        if let Some(disposal) = self.0.take() {
            disposal.dispose();
        }
    }
}