eager.cpp

 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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
#include <felspar/coro/eager.hpp>
#include <felspar/test.hpp>


namespace {


    auto const suite = felspar::testsuite("eager");


    felspar::coro::task<void> set_true(bool &s) {
        s = true;
        co_return;
    }
    auto const t = suite.test(
            "task",
            [](auto check) {
                felspar::coro::eager<> t;
                bool started = false;
                t.post(set_true, std::ref(started));
                check(started) == true;
                check(t.done()) == true;
            },
            [](auto check) {
                felspar::coro::eager<> t;
                bool started = false;
                t.post(set_true(started));
                check(started) == true;
                check(t.done()) == true;
            });


    struct boolean {
        bool value = false;

        felspar::coro::task<void> set_true() {
            value = true;
            co_return;
        }
    };
    auto const o = suite.test(
            "object",
            [](auto check) {
                felspar::coro::eager<> t;
                boolean object;
                t.post(object, &boolean::set_true);
                check(object.value) == true;
                check(t.done()) == true;
            },
            [](auto check) {
                felspar::coro::eager<> t;
                boolean object;
                t.post(object.set_true());
                check(object.value) == true;
                check(t.done()) == true;
            });


    felspar::coro::task<void> never_ends() {
        struct no_end {
            bool await_ready() const noexcept { return false; }
            void await_suspend(felspar::coro::coroutine_handle<>) noexcept {}
            void await_resume() {}
        };
        co_await no_end{};
    }
    auto const w = suite.test(
            "overwrite",
            [](auto check) {
                felspar::coro::eager<> t;
                bool started = false;
                t.post(set_true(started));
                check(started) == true;
                check(t.done()) == true;

                started = false;
                t.post(set_true(started));
                check(started) == true;
                check(t.done()) == true;
            },
            [](auto check) {
                felspar::coro::eager<> t;

                t.post(never_ends());
                check(t.done()) == false;

                t.post(never_ends());
                check(t.done()) == false;
            });


}