wf-substrate/test_trace3.erl at main · jmanhype/wf-substrate · GitHub

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
-module(test_trace3).
-compile(export_all).

test() ->
    Term = wf_term:par([
        wf_term:task(x, #{
            function => fun(Ctx) ->
                io:format("Task X running~n"),
                {ok, Ctx#{x_ran => true}}
            end
        }),
        wf_term:task(y, #{
            function => fun(Ctx) ->
                io:format("Task Y running~n"),
                {ok, Ctx#{y_ran => true}}
            end
        })
    ]),
    {ok, {Bytecode, Metadata}} = wf_compile:compile(Term),
    ExecState0 = wf_exec:new({Bytecode, Metadata}),

    ExecState1 = wf_exec:step(ExecState0, deterministic),
    io:format("Step 1: ~p~n", [element(1, ExecState1)]),

    ExecState2 = wf_exec:step(element(2, ExecState1), deterministic),
    io:format("Step 2: ~p~n", [element(1, ExecState2)]),

    ExecState3 = wf_exec:step(element(2, ExecState2), deterministic),
    io:format("Step 3: ~p~n", [element(1, ExecState3)]),

    ExecState4 = wf_exec:step(element(2, ExecState3), deterministic),
    io:format("Step 4: ~p~n", [element(1, ExecState4)]),

    ExecState5 = wf_exec:step(element(2, ExecState4), deterministic),
    io:format("Step 5: ~p~n", [element(1, ExecState5)]),

    ok.