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

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

/// A disposal that calls a callback when disposed.
#[derive(Educe)]
#[educe(Debug)]
pub struct CallbackDisposal<F: FnOnce()>(F);

impl<F: FnOnce()> CallbackDisposal<F> {
    pub fn new(callback: F) -> Self {
        Self(callback)
    }
}
impl<F: FnOnce()> Disposable for CallbackDisposal<F> {
    fn dispose(self) {
        self.0();
    }
}