use hydroflow::hydroflow_syntax; pub fn main() { let mut flow = hydroflow_syntax! { my_tee = source_iter(vec!["Hello", "world"]) -> tee(); my_tee -> map(|x| x.to_uppercase()) -> [low_road]my_union; my_tee -> map(|x| x.to_lowercase()) -> [high_road]my_union; my_union = union() -> for_each(|x| println!("{}", x)); }; println!( "{}", flow.meta_graph() .expect("No graph found, maybe failed to parse.") .to_mermaid(&Default::default()) ); flow.run_available(); }