cu-multisources 0.7.0

This is an example for the Copper project to show more advanced topologies for the DAG.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

(
    tasks: [
        (
            id: "i",
            type: "tasks::IntegerSrcTask",
        ),
        (
            id: "f",
            type: "tasks::FloatSrcTask",
        ),
        (
            id: "merger",
            type: "tasks::MergerTask"
        ),
        (
            id: "merger_sink",
            type: "tasks::MergingSinkTask",
        ),
        (
            id: "merged_sink",
            type: "tasks::MergedSinkTask",
        ),
     ],
    cnx: [
        // Make both the int and float sources send to the merging sink
        (src: "i", dst: "merger_sink", msg: "i32"),
        (src: "f", dst: "merger_sink", msg: "f32"),

        // Make both the int and float sources send to the merging tasks
        (src: "i", dst: "merger", msg: "i32"),
        (src: "f", dst: "merger", msg: "f32"),

        // Complete the graph from the merger to the merged sink
        (src: "merger", dst: "merged_sink", msg: "(i32, f32)"),
    ],
)