concepts.hpp

Go to the documentation of this file.

#pragma once
 
#include "../detail/task_adapters/traits.hpp"
#include "../slots.hpp"
 
namespace yorch {
 
template <typename Task, typename Ctx, typename Prev = no_prev>
concept adapter_wrappable_task =
    requires(Task& task, exec_context<Ctx, Prev>& ec) {
        task.invoke_raw(ec);
    } &&
    detail::declared_task_raw_result_matches_invoke_raw_v<Task, Ctx, Prev>;
 
template <typename Task, typename Ctx, typename Prev = no_prev>
concept direct_output_task =
    detail::task_uses_direct_output_protocol_v<Task> &&
    requires(Task& task, exec_context<Ctx, Prev>& ec) {
        {
            task.invoke_into(
                ec,
                direct_out<detail::declared_task_output_t<Task>> {
                    std::declval<detail::typed_slot<detail::declared_task_output_t<Task>>&>()})
        } -> std::same_as<step_result>;
    };
 
template <typename Task, typename Ctx, typename Prev = no_prev>
concept default_catchable_task =
    adapter_wrappable_task<Task, Ctx, Prev> &&
    detail::default_catch_supported_v<detail::raw_task_result_t<Task&, Ctx, Prev>>;
 
template <typename Task, typename Policy, typename Ctx, typename Prev = no_prev>
concept catch_policy_compatible_task =
    adapter_wrappable_task<Task, Ctx, Prev> &&
    detail::catch_policy_supported_v<detail::raw_task_result_t<Task&, Ctx, Prev>, Policy>;
 
template <typename Task, typename Policy, typename Ctx, typename Prev = no_prev>
concept catch_policy_compatible_direct_output_task =
    direct_output_task<Task, Ctx, Prev> &&
    std::is_nothrow_invocable_r_v<step_result, Policy&, const std::exception_ptr&>;
 
template <typename Policy>
concept retry_policy =
    requires(const std::remove_cvref_t<Policy>& policy, std::size_t retry_count) {
        { policy.should_retry(retry_count) } noexcept -> std::convertible_to<bool>;
    };
 
}  // namespace yorch