futuresdr 0.0.27

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

use std::time;

use futuresdr::anyhow::Result;
use futuresdr::blocks::FileSink;
use futuresdr::blocks::FileSource;
use futuresdr::runtime::Flowgraph;
use futuresdr::runtime::Runtime;

fn main() -> Result<()> {
    let args: Vec<String> = std::env::args().collect();

    if args.len() != 3 {
        println!("usage: file <input file> <output file>");
        return Ok(());
    }

    let mut fg = Flowgraph::new();

    let src = fg.add_block(FileSource::<u32>::new(&args[1], false));
    let snk = fg.add_block(FileSink::<f32>::new(&args[2]));

    fg.connect_stream(src, "out", snk, "in")?;

    let now = time::Instant::now();
    Runtime::new().run(fg)?;
    let elapsed = now.elapsed();

    println!("flowgraph took {:?}", elapsed);

    Ok(())
}