hydro_lang 0.16.0

A Rust framework for correct and performant distributed systems
Documentation 
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
37

// separate file for stable line numbers

#[cfg(feature = "build")]
#[test]
#[cfg_attr(not(target_os = "linux"), ignore)]
fn backtrace_chained_ops() {
    use stageleft::q;

    use crate::compile::ir::HydroRoot;
    use crate::location::Location;
    use crate::prelude::FlowBuilder;

    let mut flow = FlowBuilder::new();
    let node = flow.process::<()>();

    node.source_iter(q!([123])).for_each(q!(|_| {}));

    let finalized: crate::compile::built::BuiltFlow<'_> = flow.finalize();

    let source_meta = if let HydroRoot::ForEach { input, .. } = &finalized.ir()[0] {
        use crate::compile::ir::HydroNode;

        if let HydroNode::Source { metadata, .. } = input.as_ref() {
            &metadata.op
        } else {
            panic!()
        }
    } else {
        panic!()
    };
    let for_each_meta = finalized.ir()[0].op_metadata();

    hydro_build_utils::assert_debug_snapshot!(source_meta.backtrace.elements().collect::<Vec<_>>());
    hydro_build_utils::assert_debug_snapshot!(
        for_each_meta.backtrace.elements().collect::<Vec<_>>()
    );
}