---
source: hydroflow/tests/surface_cross_singleton.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) <code>source_stream(cross_rx)</code>"/]:::pullClass
2v1[\"(2v1) <code>sort()</code>"/]:::pullClass
3v1[/"(3v1) <code>tee()</code>"\]:::pushClass
4v1[\"(4v1) <code>defer_tick_lazy()</code>"/]:::pullClass
5v1[\"(5v1) <code>source_iter([0])</code>"/]:::pullClass
6v1[\"(6v1) <code>persist::&lt;'static&gt;()</code>"/]:::pullClass
7v1[\"(7v1) <code>union()</code>"/]:::pullClass
8v1[\"(8v1) <code>cross_singleton()</code>"/]:::pullClass
9v1[/"(9v1) <code>tee()</code>"\]:::pushClass
10v1[/"(10v1) <code>for_each(|x| egress_tx.send(x).unwrap())</code>"\]:::pushClass
11v1[\"(11v1) <code>fold(|| 0, |_, _| {})</code>"/]:::pullClass
12v1[\"(12v1) <code>cross_singleton()</code>"/]:::pullClass
13v1[\"(13v1) <code>fold(|| 0, |_, _| {})</code>"/]:::pullClass
14v1[\"(14v1) <code>flat_map(|_| [])</code>"/]:::pullClass
15v1["(15v1) <code>handoff</code>"]:::otherClass
16v1["(16v1) <code>handoff</code>"]:::otherClass
17v1["(17v1) <code>handoff</code>"]:::otherClass
18v1["(18v1) <code>handoff</code>"]:::otherClass
19v1["(19v1) <code>handoff</code>"]:::otherClass
20v1["(20v1) <code>handoff</code>"]:::otherClass
21v1["(21v1) <code>handoff</code>"]:::otherClass
22v1["(22v1) <code>handoff</code>"]:::otherClass
23v1["(23v1) <code>handoff</code>"]:::otherClass
24v1[\"(24v1) <code>identity()</code>"/]:::pullClass
25v1["(25v1) <code>handoff</code>"]:::otherClass
2v1-->3v1
1v1-->15v1
3v1-->16v1
4v1-->|0|7v1
14v1-->17v1
5v1-->6v1
6v1-->|1|7v1
7v1-->18v1
8v1-->9v1
9v1-->10v1
9v1-->19v1
3v1-->20v1
11v1-->21v1
13v1-->22v1
12v1-->23v1
15v1--x2v1; linkStyle 15 stroke:red
16v1-->|input|8v1
17v1-->24v1
18v1--x|single|8v1; linkStyle 18 stroke:red
19v1--x11v1; linkStyle 19 stroke:red
20v1-->|input|12v1
21v1--x|single|12v1; linkStyle 21 stroke:red
22v1-->14v1
23v1--x13v1; linkStyle 23 stroke:red
24v1-->25v1
25v1--o4v1; linkStyle 25 stroke:red
subgraph sg_1v1 ["sg_1v1 stratum 0"]
    1v1
    subgraph sg_1v1_var_teed_in ["var <tt>teed_in</tt>"]
        1v1
    end
end
subgraph sg_2v1 ["sg_2v1 stratum 1"]
    2v1
    3v1
    subgraph sg_2v1_var_teed_in ["var <tt>teed_in</tt>"]
        2v1
        3v1
    end
end
subgraph sg_3v1 ["sg_3v1 stratum 0"]
    4v1
    5v1
    6v1
    7v1
    subgraph sg_3v1_var_persisted_stream ["var <tt>persisted_stream</tt>"]
        5v1
        6v1
    end
    subgraph sg_3v1_var_unioned_stream ["var <tt>unioned_stream</tt>"]
        7v1
    end
end
subgraph sg_4v1 ["sg_4v1 stratum 1"]
    8v1
    9v1
    10v1
    subgraph sg_4v1_var_join ["var <tt>join</tt>"]
        8v1
        9v1
    end
end
subgraph sg_5v1 ["sg_5v1 stratum 2"]
    11v1
    subgraph sg_5v1_var_folded_thing ["var <tt>folded_thing</tt>"]
        11v1
    end
end
subgraph sg_6v1 ["sg_6v1 stratum 3"]
    12v1
    subgraph sg_6v1_var_joined_folded ["var <tt>joined_folded</tt>"]
        12v1
    end
end
subgraph sg_7v1 ["sg_7v1 stratum 4"]
    13v1
    subgraph sg_7v1_var_deferred_stream ["var <tt>deferred_stream</tt>"]
        13v1
    end
end
subgraph sg_8v1 ["sg_8v1 stratum 4"]
    14v1
    subgraph sg_8v1_var_deferred_stream ["var <tt>deferred_stream</tt>"]
        14v1
    end
end
subgraph sg_9v1 ["sg_9v1 stratum 5"]
    24v1
end