Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/source/developer/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ member functions that handle completion:
.. code-block:: cpp
struct MyReceiver {
using receiver_concept = stdexec::receiver_t;
using receiver_concept = stdexec::receiver_tag;
void set_value(int v) noexcept { /* success */ }
void set_error(std::exception_ptr e) noexcept { /* error */ }
Expand Down
2 changes: 1 addition & 1 deletion examples/algorithms/retry.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ struct _op
template <class S>
struct _retry_sender
{
using sender_concept = stdexec::sender_t;
using sender_concept = stdexec::sender_tag;
S s_;

explicit _retry_sender(S s)
Expand Down
2 changes: 1 addition & 1 deletion examples/algorithms/then.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ class _then_receiver : public exec::receiver_adaptor<_then_receiver<R, F>, R>
template <stdexec::sender S, class F>
struct _then_sender
{
using sender_concept = stdexec::sender_t;
using sender_concept = stdexec::sender_tag;

S s_;
F f_;
Expand Down
2 changes: 1 addition & 1 deletion examples/benchmark/fibonacci.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ using fib_sender = any_sender_of<stdexec::set_value_t(long)>;
template <typename Scheduler>
struct fib_s
{
using sender_concept = stdexec::sender_t;
using sender_concept = stdexec::sender_tag;
using completion_signatures = stdexec::completion_signatures<stdexec::set_value_t(long)>;

long cutoff;
Expand Down
10 changes: 5 additions & 5 deletions examples/nvexec/maxwell/snr.cuh
Original file line number Diff line number Diff line change
Expand Up @@ -33,12 +33,12 @@ namespace nvexec
{
struct stream_receiver_base
{
using receiver_concept = ex::receiver_t;
using receiver_concept = ex::receiver_tag;
};

struct stream_sender_base
{
using sender_concept = ex::sender_t;
using sender_concept = ex::sender_tag;
};

namespace detail
Expand Down Expand Up @@ -97,7 +97,7 @@ namespace _repeat_n
{
using receiver_t = OpState::receiver_t;
public:
using receiver_concept = ex::receiver_t;
using receiver_concept = ex::receiver_tag;

explicit receiver(OpState& op_state)
: opstate_(op_state)
Expand Down Expand Up @@ -198,7 +198,7 @@ namespace _repeat_n
template <class Sender, class Closure>
struct sender
{
using sender_concept = ex::sender_t;
using sender_concept = ex::sender_tag;

template <class, class Env>
static consteval auto get_completion_signatures() noexcept
Expand Down Expand Up @@ -352,7 +352,7 @@ namespace nv::execution::_strm
template <class Sender, class Closure>
struct sender
{
using sender_concept = ex::sender_t;
using sender_concept = ex::sender_tag;

using completion_signatures = ex::completion_signatures<ex::set_value_t(),
ex::set_stopped_t(),
Expand Down
4 changes: 2 additions & 2 deletions examples/problem.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace ex = stdexec;

struct receiver_t
{
using receiver_concept = ex::receiver_t;
using receiver_concept = ex::receiver_tag;

void set_value() && noexcept {}

Expand Down Expand Up @@ -78,7 +78,7 @@ struct expect_value_receiver_ex
T dest_;
Env env_{};

using receiver_concept = stdexec::receiver_t;
using receiver_concept = stdexec::receiver_tag;

explicit expect_value_receiver_ex(T dest)
: dest_(dest)
Expand Down
2 changes: 1 addition & 1 deletion examples/retry.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
// Example code:
struct fail_some
{
using sender_concept = stdexec::sender_t;
using sender_concept = stdexec::sender_tag;
using completion_signatures =
stdexec::completion_signatures<stdexec::set_value_t(int),
stdexec::set_error_t(std::exception_ptr)>;
Expand Down
2 changes: 1 addition & 1 deletion examples/scope.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ using stdexec::sync_wait;

struct noop_receiver
{
using receiver_concept = receiver_t;
using receiver_concept = receiver_tag;

template <class... _As>
void set_value(_As&&...) noexcept
Expand Down
10 changes: 5 additions & 5 deletions include/exec/any_sender_of.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -261,7 +261,7 @@ namespace experimental::execution
private:
using _base_t = STDEXEC::__any::__interface_base<_isemi_receiver, Base, _extends_base_t>;
public:
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;
using _base_t::_base_t;
};

Expand Down Expand Up @@ -402,7 +402,7 @@ namespace experimental::execution
template <class Base>
struct _iopstate : _iopstate_base_t<Base>
{
using operation_state_concept = STDEXEC::operation_state_t;
using operation_state_concept = STDEXEC::operation_state_tag;
using _iopstate_base_t<Base>::_iopstate_base_t;

virtual constexpr void start() & noexcept
Expand All @@ -425,7 +425,7 @@ namespace experimental::execution
template <class Receiver, class TargetStopToken>
struct _any_opstate
{
using operation_state_concept = STDEXEC::operation_state_t;
using operation_state_concept = STDEXEC::operation_state_tag;

template <class AnySender>
constexpr explicit _any_opstate(AnySender &&_sndr, Receiver _rcvr)
Expand Down Expand Up @@ -473,7 +473,7 @@ namespace experimental::execution
using _any_receiver_ref_t = __pointer_receiver<typename _ireceiver_t::_pointer_t>;
using _base_t = STDEXEC::__any::__interface_base<_interface_, Base, _extends_t>;
public:
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;
using _base_t::_base_t;

template <__std::derived_from<_interface_> Self, class... Env>
Expand Down Expand Up @@ -546,7 +546,7 @@ namespace experimental::execution
using _base_t =
STDEXEC::__any::__interface_base<_interface_, _inject_query_memfn_t<Base>, _extends_t>;
public:
using scheduler_concept = STDEXEC::scheduler_t;
using scheduler_concept = STDEXEC::scheduler_tag;
using _base_t::_base_t;

[[nodiscard]]
Expand Down
2 changes: 1 addition & 1 deletion include/exec/asio/completion_token.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -408,7 +408,7 @@ namespace experimental::execution::asio
{
using args_type_ = std::tuple<std::decay_t<Args>...>;
public:
using sender_concept = ::STDEXEC::sender_t;
using sender_concept = ::STDEXEC::sender_tag;

template <typename T, typename... Us>
requires std::constructible_from<Initiation, T>
Expand Down
2 changes: 1 addition & 1 deletion include/exec/asio/use_sender.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ namespace experimental::execution::asio
: s_(static_cast<T&&>(t))
{}

using sender_concept = ::STDEXEC::sender_t;
using sender_concept = ::STDEXEC::sender_tag;

template <typename Self, typename... Env>
static consteval completion_signatures<
Expand Down
12 changes: 6 additions & 6 deletions include/exec/async_scope.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ namespace experimental::execution
template <class _Constrained>
struct __when_empty_sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <class _Self, class _Receiver>
using __when_empty_opstate_t =
Expand Down Expand Up @@ -153,7 +153,7 @@ namespace experimental::execution
template <class _Receiver>
struct __nest_receiver
{
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;

static void __complete(__impl const * __scope) noexcept
{
Expand Down Expand Up @@ -240,7 +240,7 @@ namespace experimental::execution
template <class _Constrained>
struct __nest_sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <__decays_to<__nest_sender> _Self, receiver _Receiver>
requires sender_to<__copy_cvref_t<_Self, _Constrained>, __nest_receiver<_Receiver>>
Expand Down Expand Up @@ -540,7 +540,7 @@ namespace experimental::execution
template <class _Completions, class _Env>
struct __future_receiver
{
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;

constexpr void __dispatch_result_(std::unique_lock<std::mutex>& __guard) noexcept
{
Expand Down Expand Up @@ -659,7 +659,7 @@ namespace experimental::execution
using __future_opstate_t = __future_opstate<_Sender, _Env, _Receiver>;

public:
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

__future(__future&&) = default;
auto operator=(__future&&) -> __future& = default;
Expand Down Expand Up @@ -747,7 +747,7 @@ namespace experimental::execution
template <class _Env>
struct __spawn_receiver
{
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;

constexpr void set_value() noexcept
{
Expand Down
4 changes: 2 additions & 2 deletions include/exec/at_coroutine_exit.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ namespace experimental::execution
template <class _Receiver>
struct __receiver
{
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;

template <class... _Args>
requires __callable<set_value_t, _Receiver, _Args...>
Expand Down Expand Up @@ -71,7 +71,7 @@ namespace experimental::execution
template <class _Sender>
struct __sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <class... _Env>
using __completions_t = __mapply<__mremove<set_stopped_t(), __q<completion_signatures>>,
Expand Down
2 changes: 1 addition & 1 deletion include/exec/completion_signatures.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ namespace experimental::execution
//! template <class Child, class Fn>
//! struct then_sender
//! {
//! using sender_concept = ex::sender_t;
//! using sender_concept = ex::sender_tag;
//!
//! template <class Self, class... Env>
//! static consteval auto get_completion_signatures()
Expand Down
2 changes: 1 addition & 1 deletion include/exec/create.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ namespace experimental::execution
template <class _Fun, class _Args, class... _Sigs>
struct __sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;
using completion_signatures = STDEXEC::completion_signatures<_Sigs...>;

template <__decays_to<__sender> _Self, receiver_of<completion_signatures> _Receiver>
Expand Down
4 changes: 2 additions & 2 deletions include/exec/detail/shared.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ namespace experimental::execution::__shared
template <class _Env, class _Variant>
struct __receiver
{
using receiver_concept = receiver_t;
using receiver_concept = receiver_tag;
template <class... _As>
STDEXEC_ATTRIBUTE(always_inline)
constexpr void set_value(_As&&... __as) noexcept
Expand Down Expand Up @@ -509,7 +509,7 @@ namespace experimental::execution::__shared
template <class _Tag, class _CvChild, class _Env>
struct __sndr : __if_c<__same_as<_Tag, split_t>, __empty, __move_only>
{
using sender_concept = sender_t;
using sender_concept = sender_tag;
using __tag_t = _Tag;

constexpr explicit __sndr(_Tag, _CvChild&& __child, _Env __env)
Expand Down
4 changes: 2 additions & 2 deletions include/exec/env.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ namespace experimental::execution
template <class _Tag, class _Default>
struct __sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <class _Env>
using __value_t =
Expand Down Expand Up @@ -219,7 +219,7 @@ namespace experimental::execution
template <class _Sender, class _Attrs>
struct __sender
{
using sender_concept = sender_t;
using sender_concept = sender_tag;

constexpr auto get_env() const noexcept -> __join_env_t<_Attrs const &, env_of_t<_Sender>>
{
Expand Down
6 changes: 3 additions & 3 deletions include/exec/fork_join.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -93,12 +93,12 @@ namespace experimental::execution
template <class Variant, class Domain>
struct _cache_sndr_t
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <class Rcvr>
struct _opstate_t
{
using operation_state_concept = STDEXEC::operation_state_t;
using operation_state_concept = STDEXEC::operation_state_tag;

STDEXEC_ATTRIBUTE(host, device) void start() noexcept
{
Expand Down Expand Up @@ -140,7 +140,7 @@ namespace experimental::execution
template <class Sndr, class Closures, class Rcvr>
struct _opstate_t
{
using operation_state_concept = STDEXEC::operation_state_t;
using operation_state_concept = STDEXEC::operation_state_tag;
using _env_t = STDEXEC::__fwd_env_t<STDEXEC::env_of_t<Rcvr>>;
using _child_completions_t = STDEXEC::__completion_signatures_of_t<Sndr, _env_t>;
using _domain_t = STDEXEC::__completion_domain_of_t<STDEXEC::set_value_t, Sndr, _env_t>;
Expand Down
4 changes: 2 additions & 2 deletions include/exec/just_from.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ namespace experimental::execution
template <class Rcvr, class Fn>
struct _opstate
{
using operation_state_concept = STDEXEC::operation_state_t;
using operation_state_concept = STDEXEC::operation_state_tag;

Rcvr _rcvr;
Fn _fn;
Expand Down Expand Up @@ -138,7 +138,7 @@ namespace experimental::execution
template <class Fn>
struct _sndr_base
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;
using completion_signatures = _completions<Fn>;

STDEXEC_ATTRIBUTE(no_unique_address) JustTag _tag;
Expand Down
6 changes: 3 additions & 3 deletions include/exec/libdispatch_queue.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ namespace experimental::execution

struct sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;
using completion_signatures =
STDEXEC::completion_signatures<STDEXEC::set_value_t(), STDEXEC::set_stopped_t()>;

Expand Down Expand Up @@ -251,7 +251,7 @@ namespace experimental::execution
template <class Sender, std::integral Shape, class Fun>
struct bulk_sender
{
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

template <class CvSender, class... Env>
using with_error_invoke_t = STDEXEC::__if_c<
Expand Down Expand Up @@ -426,7 +426,7 @@ namespace experimental::execution
template <class CvSender, class Receiver, class Shape, class Fun, bool MayThrow>
struct bulk_receiver
{
using receiver_concept = STDEXEC::receiver_t;
using receiver_concept = STDEXEC::receiver_tag;

using shared_state = bulk_shared_state<CvSender, Receiver, Shape, Fun, MayThrow>;

Expand Down
6 changes: 3 additions & 3 deletions include/exec/linux/io_uring_context.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -685,7 +685,7 @@ namespace experimental::execution
class __run_sender
{
public:
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;
using completion_signatures =
STDEXEC::completion_signatures<STDEXEC::set_value_t(),
STDEXEC::set_error_t(std::exception_ptr),
Expand Down Expand Up @@ -1250,7 +1250,7 @@ namespace experimental::execution
__schedule_env __env_;

public:
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

explicit __schedule_sender(__schedule_env __env) noexcept
: __env_{__env}
Expand Down Expand Up @@ -1286,7 +1286,7 @@ namespace experimental::execution
STDEXEC::set_stopped_t()>;

public:
using sender_concept = STDEXEC::sender_t;
using sender_concept = STDEXEC::sender_tag;

__schedule_env __env_;
std::chrono::nanoseconds __duration_;
Expand Down
Loading
Loading