rerust 0.1.0

Reactive programming with dataflow semantics
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

use std::{cell::RefCell, rc::Rc};

mod generated {
    use rerust::rerust;

    rerust! {
        let x = Var::<u32>(1u32);
        let y = x.map(|x: &u32| -> u32 {x * 2});
        let z = x.map(|x: &u32| -> u32 {x * 3});
        let pin t = (y,z).map(|y: &u32, z: &u32| -> u32 {y + z});
    }
}

fn main() {
    let mut prog = generated::Program::new();
    let mut sink = prog.sink();

    let observer = Rc::new(RefCell::new(observer_cb)) as Rc<_>;
    prog.observe_t(Rc::downgrade(&observer));

    sink.send_x(2);
    prog.init();
    for _ in 0..5 {
        prog.run();
    }
}

fn observer_cb(t: &u32) {
    println!("t: {:?}", t);
}