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
|
// This file is part of CAF, the C++ Actor Framework. See the file LICENSE in
// the main distribution directory for license terms and copyright or visit
// https://github.com/actor-framework/actor-framework/blob/master/LICENSE.
#define CAF_SUITE unit
#include "caf/unit.hpp"
#include "core-test.hpp"
#include "caf/actor_system.hpp"
#include "caf/actor_system_config.hpp"
#include "caf/event_based_actor.hpp"
#include "caf/scoped_actor.hpp"
using namespace caf;
behavior testee(event_based_actor* self) {
return {
[](add_atom) -> result<unit_t> { return unit; },
[](get_atom) -> result<void> { return {}; },
[](put_atom) -> unit_t { return unit; },
[](resolve_atom) -> void {},
[=](update_atom) -> result<unit_t> {
auto rp = self->make_response_promise<unit_t>();
rp.deliver(unit);
return rp;
},
};
}
CAF_TEST(unit_results) {
actor_system_config cfg;
actor_system sys{cfg};
scoped_actor self{sys};
auto aut = sys.spawn(testee);
message as[] = {
make_message(add_atom_v), make_message(get_atom_v),
make_message(put_atom_v), make_message(resolve_atom_v),
make_message(update_atom_v),
};
for (auto a : as) {
self->request(aut, infinite, a)
.receive(
[&] {
MESSAGE("actor under test correctly replied to " << to_string(a));
},
[&](const error&) {
CAF_FAIL("actor under test failed at input " << to_string(a));
});
}
}
|
