Struct cfrp::Topology

pub struct Topology {
    // some fields omitted
}

Topology<T> describes a data flow and controls its execution

Methods

impl Topology

fn new(inputs: Vec<Box<RunInput>>, runners: Vec<Box<Run>>) -> Self

Create a new topology

fn run(self) -> TopologyHandle

Run the topology