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
|
#include <string>
#include "promise.hpp"
using promise::promise_t;
int main() {
std::function<void()> t1;
std::function<void()> t2;
std::function<void()> t3;
std::function<void()> t4;
std::function<void()> t5;
auto pm = promise_t([&t1](promise_t pm) {
puts("pm1");
//t1 = [pm]() {pm.reject(5);};
t1 = [pm]() {pm.resolve(5);};
}).then(std::function<int(int)>([](int x) {
printf("%d\n", x);
return 6;
})).then(std::function<int(int)>([](int y) {
printf("%d\n", y);
return 0;
})).then(std::function<promise_t(int)>([&t2](int x) {
auto pm2 = promise_t([x, &t2](promise_t pm2) {
printf("pm2 %d\n", x);
t2 = [pm2]() {pm2.resolve(std::string("hello"));};
});
return pm2;
})).then(std::function<int(std::string)>([](std::string s) {
printf("%s\n", s.c_str());
return 10;
})).then(std::function<promise::None(int)>([](int x) {
printf("%d\n", x);
return promise::none;
}));
auto p1 = promise_t([&t4](promise_t pm) {
puts("p1");
t4 = [pm]() {pm.resolve(1);};
});
auto p2 = promise_t([&t5](promise_t pm) {
puts("p2");
t5 = [pm]() {pm.resolve(std::string("hello"));};
});
auto p3 = promise_t([&t3](promise_t pm) {
puts("p3");
t3 = [pm]() {pm.resolve(std::string("world"));};
});
auto p4 = promise::all(std::vector<promise_t>{p1, p2, p3})
.then(std::function<int(promise::values_t)>(
[](const promise::values_t values) {
printf("%d %s %s\n", std::any_cast<int>(values[0]),
std::any_cast<std::string>(values[1]).c_str(),
std::any_cast<std::string>(values[2]).c_str());
return 100;
}));
auto p5 = promise::all(std::vector<promise_t>{pm, p4})
.fail(std::function<int(int)>(
[](int reason) {
printf("reason: %d\n", reason);
return reason;
}))
.then(std::function<promise::None(promise::values_t)>(
[](const promise::values_t values) {
printf("finally %d\n", std::any_cast<int>(values[1]));
return promise::none;
}));
puts("calling t");
t4();
puts("calling t2");
t5();
puts("calling t3");
t3();
t1();
printf("=== after ===\n");
t2();
}
|