just_stopped.hpp

Go to the documentation of this file.

#ifndef KOKKOS_EXECUTION_TESTS_UTILS_JUST_STOPPED_HPP
#define KOKKOS_EXECUTION_TESTS_UTILS_JUST_STOPPED_HPP
 
#include "kokkos-execution/stdexec.hpp"
 
#include "tests/utils/stdexec.hpp"
 
namespace Tests::Utils {
 
template <typename SchedulerType, typename Tag, typename... Args>
consteval bool check_continues_on_after_just_stopped() {
    using sndr_t =
        decltype(stdexec::just_stopped() | stdexec::continues_on(std::declval<SchedulerType>()) | Tag{}(std::declval<Args>()...));
 
    static_assert(!stdexec::dependent_sender<sndr_t>);
    static_assert(
        stdexec::get_completion_signatures<sndr_t>() == stdexec::completion_signatures<stdexec::set_stopped_t()>{});
    static_assert(
        stdexec::get_completion_signatures<sndr_t, stdexec::env<>>()
        == stdexec::completion_signatures<stdexec::set_stopped_t()>{});

 
    return true;
}
 
} // namespace Tests::Utils
 
#endif // KOKKOS_EXECUTION_TESTS_UTILS_JUST_STOPPED_HPP