Asyn_scope query

[abhilashraju]

Asyn_scope query

[janondrusek]

Updated your example: https://godbolt.org/z/8eheK6Kz7

Looks like -fconcepts is not playing well with the library.

#include <iostream>
#include <utility>

#include <unifex/async_scope.hpp>
#include <unifex/inline_scheduler.hpp>
#include <unifex/just.hpp>
#include <unifex/just_error.hpp>
#include <unifex/just_from.hpp>
#include <unifex/let_error.hpp>
#include <unifex/let_value.hpp>
#include <unifex/static_thread_pool.hpp>
#include <unifex/sync_wait.hpp>
#include <unifex/then.hpp>
#include <unifex/upon_error.hpp>
#include <unifex/when_all.hpp>

using namespace unifex;

template <typename Handler>
struct on_error {
    Handler h;
    on_error(Handler h) : h(std::move(h)) {}

    template <typename Sender>
    friend auto operator|(Sender&& sender, on_error error) {
        return sender | let_error([](auto v) { return just_error(v); }) |
               upon_error([error = std::move(error)](auto exptr) {
                   try {
                       rethrow_exception(exptr);
                   } catch (std::runtime_error e) {
                       std::cout << e.what() << "\n";
                   }
                   error.h();
               });
    }
};

int main() {
    auto add_42 = then(just_from([]() noexcept {
                           std::cout << "Hello world! Have an int.\n";
                           return 13;
                       }),
                       [](auto&& arg) noexcept { std::cout << arg + 42 << "\n"; });
    auto leterror = add_42 | on_error([]() { std::cout << "hello"; });

    async_scope scope;
    scope.spawn(std::move(leterror));
    sync_wait(scope.complete());
    // auto(i) = sync_wait(std::move(leterror)).value(); // 5
}

/*
Output:
ASM generation compiler returned: 0
Execution build compiler returned: 0
Program returned: 0
Hello world! Have an int.
55
*/