--- source: hydroflow/tests/surface_persist.rs expression: "df.meta_graph().unwrap().to_mermaid(&Default::default())" --- %%{init:{'theme':'base','themeVariables':{'clusterBkg':'#ddd','clusterBorder':'#888'}}}%% flowchart TD classDef pullClass fill:#8af,stroke:#000,text-align:left,white-space:pre classDef pushClass fill:#ff8,stroke:#000,text-align:left,white-space:pre classDef otherClass fill:#fdc,stroke:#000,text-align:left,white-space:pre linkStyle default stroke:#aaa 1v1[\"(1v1) source_iter([1, 2, 3])"/]:::pullClass 2v1[\"(2v1) persist::<'static>()"/]:::pullClass 3v1[/"(3v1) tee()"\]:::pushClass 4v1[/"(4v1) for_each(|v| pull_tx.send(v).unwrap())"\]:::pushClass 5v1[/"(5v1) persist::<'static>()"\]:::pushClass 6v1[/"(6v1) for_each(|v| push_tx.send(v).unwrap())"\]:::pushClass 2v1-->3v1 1v1-->2v1 3v1-->4v1 5v1-->6v1 3v1-->5v1 subgraph sg_1v1 ["sg_1v1 stratum 0"] 1v1 2v1 3v1 4v1 5v1 6v1 subgraph sg_1v1_var_my_tee ["var my_tee"] 1v1 2v1 3v1 end end