futuresdr 0.0.39

An Experimental Async SDR Runtime for Heterogeneous Architectures.
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

use anyhow::Result;
use futuresdr::blocks::Split;
use futuresdr::blocks::VectorSink;
use futuresdr::blocks::VectorSource;
use futuresdr::num_complex::Complex;
use futuresdr::prelude::*;

#[test]
fn split_const_fn() -> Result<()> {
    let mut fg = Flowgraph::new();

    let input = (0..10).map(|x| Complex::new(x, x + 1)).collect();
    let src = VectorSource::<Complex<i32>>::new(input);
    let split: Split<_, _, _, _> = Split::new(|a: &Complex<i32>| -> (i32, i32) { (a.re, a.im) });
    let snk0 = VectorSink::<i32>::new(10);
    let snk1 = VectorSink::<i32>::new(10);

    connect!(fg, src > input.split.output0 > snk0; split.output1 > snk1);

    Runtime::new().run(fg)?;

    let snk = snk0.get()?;
    let v = snk.items();

    let res = 0..10;
    assert_eq!(v.len(), res.len());
    for (o, i) in res.zip(v) {
        assert_eq!(o, *i);
    }

    let snk = snk1.get()?;
    let v = snk.items();

    let res = 1..11;
    assert_eq!(v.len(), res.len());
    for (o, i) in res.zip(v) {
        assert_eq!(o, *i);
    }

    Ok(())
}