Struct MTGraph 

pub struct MTGraph { /* private fields */ }

A graph is a thing that RustRadio runs, to let blocks “talk to each other” via streams.

Example

use rustradio::graph::GraphRunner;
use rustradio::mtgraph::MTGraph;
use rustradio::Complex;
use rustradio::blocks::{FileSource,RtlSdrDecode,AddConst,NullSink};
let (src, prev) = FileSource::new("/dev/null")?;
let (dec, prev) = RtlSdrDecode::new(prev);
let (add, prev) = AddConst::new(prev, Complex::new(1.1, 2.0));
let sink = NullSink::new(prev);
let mut g = MTGraph::new();
g.add(Box::new(src));
g.add(Box::new(dec));
g.add(Box::new(add));
g.add(Box::new(sink));
g.run()?;

Implementations

impl MTGraph

pub fn new() -> Self

Create a new flowgraph.

Trait Implementations

impl Default for MTGraph

fn default() -> Self

Returns the “default value” for a type.

impl GraphRunner for MTGraph

fn generate_stats(&self) -> Option<String>

Return a string with stats about where time went.

MTGraph can’t measure per block CPU time, since rayon and other block threading is not measurable.

fn add(&mut self, b: Box<dyn Block + Send>)

Add a block to the graph.

fn run(&mut self) -> Result<()>

Run the graph.

fn cancel_token(&self) -> CancellationToken

Return a cancellation token, for asynchronously stopping the graph, for example if the user presses Ctrl-C.