Struct cfrp::Topology

pub struct Topology { /* 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