sync_wait.h

Go to the documentation of this file.

#pragma once
#include <asyncpp/fire_and_forget.h>
#include <future>
 
namespace asyncpp {
    template<typename T, typename Awaitable>
    std::future<T> as_promise(Awaitable&& awaiter)
        requires(!std::is_void_v<T>)
    {
        std::promise<T> promise;
        auto res = promise.get_future();
        [](std::decay_t<Awaitable> awaiter, std::promise<T> promise) -> eager_fire_and_forget_task<> {
            try {
                promise.set_value(co_await std::move(awaiter));
            } catch (...) { promise.set_exception(std::current_exception()); }
        }(std::forward<decltype(awaiter)>(awaiter), std::move(promise));
        return res;
    }
 
    template<typename T, typename Awaitable>
    std::future<void> as_promise(Awaitable&& awaiter)
        requires(std::is_void_v<T>)
    {
        std::promise<void> promise;
        auto res = promise.get_future();
        [](std::decay_t<Awaitable> awaiter, std::promise<void> promise) -> eager_fire_and_forget_task<> {
            try {
                co_await std::move(awaiter);
                promise.set_value();
            } catch (...) { promise.set_exception(std::current_exception()); }
        }(std::forward<decltype(awaiter)>(awaiter), std::move(promise));
        return res;
    }
 
    auto as_promise(auto&& awaiter) {
        return as_promise<typename detail::await_return_type<std::remove_cvref_t<decltype(awaiter)>>::type>(
            std::forward<decltype(awaiter)>(awaiter));
    }
} // namespace asyncpp