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

use anyhow::Result;
use futuresdr::blocks::Head;
use futuresdr::blocks::NullSink;
use futuresdr::blocks::NullSource;
use futuresdr::prelude::*;

fn main() -> Result<()> {
    let mut fg = Flowgraph::new();

    let src = NullSource::<u8>::new();
    let head = Head::<u8>::new(1234);
    let snk = NullSink::<u8>::new();

    // type erasure for src
    let src = fg.add_block(src);
    let src: BlockId = src.into();

    let head = fg.add_block(head);

    // untyped connect
    fg.connect_dyn(src, "output", &head, "input")?;
    // typed connect
    connect!(fg, head > snk);

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