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
39
40
41
42
43
44
45

mod tests_utils;

use rx_rust::disposable::{
    Disposable, boxed_disposal::BoxedDisposal, callback_disposal::CallbackDisposal,
};
use tests_utils::test_struct::TestStruct;

#[test]
fn test_callback_disposal() {
    let mut called = false;
    let disposal = CallbackDisposal::new(|| {
        called = true;
    });
    disposal.dispose();
    assert!(called);
}

#[test]
fn test_boxed_disposal() {
    let mut called = false;
    let disposal = CallbackDisposal::new(|| {
        called = true;
    });
    let disposal = BoxedDisposal::new(disposal);
    disposal.dispose();
    assert!(called);
}

#[test]
fn test_lifetime_boxed() {
    // OK
    let life_marker = TestStruct;
    let _disposal;

    // Error
    // let _disposal;
    // let life_marker = TestStruct;

    {
        let callback_disposal = CallbackDisposal::new(|| {
            life_marker.consume_ref();
        });
        _disposal = BoxedDisposal::new(callback_disposal);
    }
}