xi 0.1.1

A functional reactive stream library for rust
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

#[macro_use]
extern crate criterion;

use criterion::Criterion;

use xi::Stream;

fn map_benchmark(c: &mut Criterion) {
    let sink = Stream::sink();
    let map = sink.stream().map(|x| x * 2);
    let _ = map.subscribe(|_| {});
    c.bench_function("map", move |b| b.iter(|| sink.update(42)));
}

fn imitator_benchmark(c: &mut Criterion) {
    let imitator = Stream::imitator();

    let fold = imitator
        .stream()
        .fold(1, |p, c| if *c < 10 { p + c } else { p })
        .dedupe();

    let sink = Stream::sink();

    let merge = Stream::merge(vec![fold, sink.stream()]);
    imitator.imitate(&merge);

    let _ = merge.subscribe(|_| {});

    c.bench_function("imitator", move |b| b.iter(|| sink.update(1)));
}

criterion_group!(benches, map_benchmark, imitator_benchmark);
criterion_main!(benches);