44 std::vector<cppext::future_queue<double>> temp;
46 temp.push_back(inputQueue1.then<
double>([](
int x) { return x / 2.; }));
47 temp.push_back(inputQueue2.then<
double>([](
int x) { return x * 3.; }));
51 auto result12 = when12.then<
double>([temp]()
mutable {
64 std::vector<cppext::future_queue_base> temp2;
65 temp2.push_back(result12);
66 temp2.push_back(inputQueue3);
70 for(
size_t i = 0; i < 10; ++i) {
72 ready.pop_wait(index);
76 std::cout << value << std::endl;
80 inputQueue3.pop(value);
81 std::cout << value << std::endl;