Struct DataflowGraph 

pub struct DataflowGraph { /* private fields */ }

A typed node descriptor for building the graph with DataflowGraph.

The graph stores nodes as typed variants internally; connections between nodes of compatible types are resolved at run() time.

Implementations

impl DataflowGraph

pub fn new() -> Self

Create a new, empty graph.

pub fn add_source(&mut self, src: Source<i32>) -> NodeId

Add an i32 source node and return its NodeId.

pub fn add_map(&mut self, map: Map<i32, i32>) -> NodeId

Add an i32 → i32 map node and return its NodeId.

pub fn add_filter(&mut self, filter: Filter<i32>) -> NodeId

Add an i32 filter node and return its NodeId.

pub fn add_sink(&mut self, sink: Sink<i32>) -> NodeId

Add an i32 sink node and return its NodeId.

pub fn add_buffer(&mut self, buf: Buffer<i32>) -> NodeId

Add an i32 buffer node and return its NodeId.

pub fn add_source_f64(&mut self, src: Source<f64>) -> NodeId

Add an f64 source node and return its NodeId.

pub fn add_sink_f64(&mut self, sink: Sink<f64>) -> NodeId

Add an f64 sink node and return its NodeId.

pub fn connect(&mut self, src: NodeId, dst: NodeId)

Connect the output of src to the input of dst.

pub fn run(&self)

Drive all source nodes and push values through the graph until all sources are empty.

pub fn collect_sink(&self, id: NodeId) -> Vec<i32>

Collect and drain all values accumulated in the i32 sink at id.

pub fn collect_sink_f64(&self, id: NodeId) -> Vec<f64>

Collect and drain all values accumulated in the f64 sink at id.

pub fn collect_buffer(&self, id: NodeId) -> Vec<Vec<i32>>

Return available batches from a Buffer node at id.