Home
last modified time | relevance | path

Searched refs:_Sender (Results 1 – 25 of 46) sorted by relevance

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__domain.hpp58 template <class _DomainOrTag, class _Sender, class... _Env>
60 requires(_DomainOrTag __tag, _Sender&& __sender, const _Env&... __env) {
61 __tag.transform_sender(static_cast<_Sender&&>(__sender), __env...);
64 template <class _Sender, class... _Env>
66 sender_expr<_Sender> //
67 && __has_transform_sender<tag_of_t<_Sender>, _Sender, _Env...>;
69 template <class _Type, class _Sender, class _Env>
71 requires(_Type __obj, _Sender&& __sender, _Env&& __env) {
72 __obj.transform_env(static_cast<_Sender&&>(__sender),
76 template <class _Sender, class _Env>
[all …]
H A D__sync_wait.hpp70 template <class _Sender, class _Continuation>
72 __value_types_of_t<_Sender, __env,
76 template <class _Sender>
78 __mtry_eval<__sync_wait_result_impl, _Sender, __qq<std::tuple>>;
80 template <class _Sender>
82 __mtry_eval<__sync_wait_result_impl, __result_of<into_variant, _Sender>,
150 template <class _Sender>
151 using __receiver_t = __t<__sync_wait_result_impl<_Sender, __q<__receiver>>>;
154 template <class _Sender>
157 using __t = __receiver_t<_Sender>;
[all …]
H A D__senders.hpp53 template <class _Sender, class _Env>
55 transform_sender_result_t<__late_domain_of_t<_Sender, _Env>, _Sender, _Env>;
57 template <class _Sender, class... _Env>
59 decltype(__declval<_Sender>().get_completion_signatures(
62 template <class _Sender, class... _Env>
64 decltype(STDEXEC_REMOVE_REFERENCE(_Sender) //
65 ::get_completion_signatures(__declval<_Sender>(),
68 template <class _Sender, class... _Env>
69 concept __with_member = __mvalid<__member_result_t, _Sender, _Env...>;
71 template <class _Sender, class... _Env>
[all …]
H A D__sender_adaptor_closure.hpp41 template <class _Tp, class _Sender>
44 && sender<__decay_t<_Sender>> //
45 && __callable<_Tp, __decay_t<_Sender>> //
46 && sender<__call_result_t<_Tp, __decay_t<_Sender>>>;
58 template <sender _Sender>
59 requires __callable<_T0, _Sender> &&
60 __callable<_T1, __call_result_t<_T0, _Sender>>
62 __call_result_t<_T1, __call_result_t<_T0, _Sender>> operator()( in operator ()()
63 _Sender&& __sndr) && in operator ()()
66 static_cast<_T0&&>(__t0_)(static_cast<_Sender&&>(__sndr))); in operator ()()
[all …]
H A D__transform_sender.hpp39 template <class _Sender, class _Env>
42 template <sender_expr _Sender, class _Env>
43 requires same_as<__early_domain_of_t<_Sender>, dependent_domain>
45 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const
46 noexcept(__is_nothrow_transform_sender<_Sender, _Env>());
55 template <class _Domain, class _Sender, class _Env>
58 decltype(auto) operator()(_Domain __dom, _Sender&& __sndr, in operator ()()
61 if constexpr (__domain::__has_transform_env<_Domain, _Sender, _Env>) in operator ()()
63 return __dom.transform_env(static_cast<_Sender&&>(__sndr), in operator ()()
69 static_cast<_Sender&&>(__sndr), static_cast<_Env&&>(__env)); in operator ()()
[all …]
H A D__sender_introspection.hpp27 template <class _Sender, class _ApplyFn>
29 auto operator()(_Sender&& __sndr, _ApplyFn&& __fun) const // in operator ()()
30 noexcept(noexcept(__sndr.apply(static_cast<_Sender&&>(__sndr), in operator ()()
32 -> decltype(__sndr.apply(static_cast<_Sender&&>(__sndr), in operator ()()
35 return __sndr.apply(static_cast<_Sender&&>(__sndr), in operator ()()
64 template <class _Sender>
65 using __desc_of = __sexpr_uncurry<_Sender, __q<__desc>>;
73 template <class _Sender, class _ApplyFn>
75 __call_result_t<__sexpr_apply_t, _Sender, _ApplyFn>;
77 template <class _Sender>
[all …]
H A D__senders_core.hpp40 template <class _Sender>
42 derived_from<typename _Sender::sender_concept, sender_t> ||
43 requires { typename _Sender::is_sender; } // NOT TO SPEC back compat
44 || __awaitable<_Sender, __env::__promise<empty_env>>;
47 template <class _Sender>
48 inline constexpr bool enable_sender = __detail::__enable_sender<_Sender>;
50 template <class _Sender>
52 enable_sender<__decay_t<_Sender>> //
53 && environment_provider<__cref_t<_Sender>> //
54 && __detail::__consistent_completion_domains<_Sender> //
[all …]
H A D__ensure_started.hpp46 template <sender _Sender, class _Env = empty_env>
47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
48 [[nodiscard]] auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
51 if constexpr (sender_expr_for<_Sender, __ensure_started_t>)
53 return static_cast<_Sender&&>(__sndr);
61 static_cast<_Sender&&>(__sndr)));
71 using _Sender = __1; typedef
75 get_env_t(const _Sender&)),
76 _Sender),
77 tag_invoke_t(ensure_started_t, _Sender)>;
[all …]
H A D__split.hpp46 template <sender _Sender, class _Env = empty_env>
47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
48 auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
54 static_cast<_Sender&&>(__sndr)));
63 using _Sender = __1; typedef
67 get_env_t(const _Sender&)),
68 _Sender),
69 tag_invoke_t(split_t, _Sender)>;
75 template <class _Sender>
76 static auto transform_sender(_Sender&& __sndr) in transform_sender()
[all …]
H A D__start_detached.hpp71 template <sender_in<__root_env> _Sender>
72 requires __callable<apply_sender_t, __early_domain_of_t<_Sender>,
73 start_detached_t, _Sender>
74 void operator()(_Sender&& __sndr) const in operator ()()
77 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr)); in operator ()()
80 template <class _Env, sender_in<__as_root_env_t<_Env>> _Sender>
82 __late_domain_of_t<_Sender, __as_root_env_t<_Env>>,
83 start_detached_t, _Sender, __as_root_env_t<_Env>>
84 void operator()(_Sender&& __sndr, _Env&& __env) const in operator ()()
87 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr), in operator ()()
[all …]
H A D__transform_completion_signatures.hpp38 template <class _Sender, class... _Env>
39 auto __checked_completion_signatures(_Sender&& __sndr, _Env&&... __env) noexcept in __checked_completion_signatures()
41 using __completions_t = __completion_signatures_of_t<_Sender, _Env...>; in __checked_completion_signatures()
42 stdexec::__debug_sender(static_cast<_Sender&&>(__sndr), __env...); in __checked_completion_signatures()
46 template <class _Sender, class... _Env>
47 requires sender_in<_Sender, _Env...>
49 decltype(stdexec::__checked_completion_signatures(__declval<_Sender>(),
52 template <class _Sender, class... _Env>
53 requires sender_in<_Sender, _Env...>
55 __completion_signatures_of_t<_Sender, _Env...>;
[all …]
H A D__continues_on.hpp47 template <class _Sender>
49 __result_of<schedule_from, __scheduler_t<__data_of<_Sender>>,
50 __child_of<_Sender>>;
54 template <sender _Sender, scheduler _Scheduler>
55 auto operator()(_Sender&& __sndr, _Scheduler&& __sched) const in operator ()()
63 static_cast<_Sender&&>(__sndr))); in operator ()()
76 using _Sender = __1; typedef
80 get_env_t(const _Sender&)),
81 _Sender,
83 tag_invoke_t(continues_on_t, _Sender,
[all …]
H A D__continue_on.hpp47 template <class _Sender>
49 __result_of<schedule_from, __scheduler_t<__data_of<_Sender>>,
50 __child_of<_Sender>>;
54 template <sender _Sender, scheduler _Scheduler>
55 auto operator()(_Sender&& __sndr, _Scheduler&& __sched) const in operator ()()
63 static_cast<_Sender&&>(__sndr))); in operator ()()
76 using _Sender = __1; typedef
80 get_env_t(const _Sender&)),
81 _Sender,
83 tag_invoke_t(continue_on_t, _Sender,
[all …]
H A D__start_on.hpp58 using _Sender = __1; typedef
61 __types<tag_invoke_t(start_on_t, _Scheduler, _Sender)>;
63 template <scheduler _Scheduler, sender _Sender>
64 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
71 static_cast<_Sender&&>(__sndr))); in operator ()()
83 template <class _Sender, class _Env>
84 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
90 template <class _Sender, class _Env>
91 static auto transform_sender(_Sender&& __sndr, const _Env&) in transform_sender()
94 static_cast<_Sender&&>(__sndr), in transform_sender()
[all …]
H A D__starts_on.hpp59 using _Sender = __1; typedef
62 __types<tag_invoke_t(starts_on_t, _Scheduler, _Sender)>;
64 template <scheduler _Scheduler, sender _Sender>
65 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
72 static_cast<_Sender&&>(__sndr))); in operator ()()
84 template <class _Sender, class _Env>
85 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
91 template <class _Sender, class _Env>
92 static auto transform_sender(_Sender&& __sndr, const _Env&) in transform_sender()
95 static_cast<_Sender&&>(__sndr), in transform_sender()
[all …]
H A D__when_all.hpp79 template <class _Sender, class _Env>
81 sender_in<_Sender, _Env> && __mvalid<__value_types_of_t, _Sender, _Env,
91 template <class _Sender, class... _Env>
93 __mexception<_INVALID_WHEN_ALL_ARGUMENT_<>, _WITH_SENDER_<_Sender>,
103 template <class _Sender, class... _Env>
106 __completion_signatures_of_t<_Sender, _Env...>,
116 template <class _Sender, class _ValueTuple, class... _Rest>
120 _Sender, _Env...>;
122 template <class _Sender>
124 __value_types_t<__completion_signatures_of_t<_Sender, _Env...>,
[all …]
H A D__on.hpp60 template <class _Sender, class _Env>
69 _WITH_SENDER_<_Sender>, _WITH_ENVIRONMENT_<_Env>>{}; in get_completion_signatures()
107 template <scheduler _Scheduler, sender _Sender>
108 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
114 static_cast<_Sender&&>(__sndr))); in operator ()()
117 template <sender _Sender, scheduler _Scheduler,
118 __sender_adaptor_closure_for<_Sender> _Closure>
119 auto operator()(_Sender&& __sndr, _Scheduler&& __sched, in operator ()()
127 static_cast<_Sender&&>(__sndr))); in operator ()()
220 template <class _Sender, class _Env>
[all …]
H A D__bulk.hpp80 template <sender _Sender, integral _Shape, __movable_value _Fun>
82 auto operator()(_Sender&& __sndr, _Shape __shape, _Fun __fun) const in operator ()()
89 static_cast<_Sender&&>(__sndr))); in operator ()()
104 using _Sender = __1; typedef
110 get_env_t(_Sender&)),
111 _Sender, _Shape, _Fun),
112 tag_invoke_t(bulk_t, _Sender, _Shape, _Fun)>;
117 template <class _Sender>
118 using __fun_t = decltype(__decay_t<__data_of<_Sender>>::__fun_);
120 template <class _Sender>
[all …]
H A D__then.hpp52 template <sender _Sender, __movable_value _Fun>
53 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
59 static_cast<_Sender&&>(__sndr))); in operator ()()
69 using _Sender = __1; typedef
74 get_env_t(_Sender&)),
75 _Sender, _Fun),
76 tag_invoke_t(then_t, _Sender, _Fun)>;
82 []<class _Sender, class... _Env>(_Sender&&, _Env&&...) noexcept
83 -> __completions_t<__decay_t<__data_of<_Sender>>, __child_of<_Sender>,
85 static_assert(sender_expr_for<_Sender, then_t>);
H A D__upon_stopped.hpp52 template <sender _Sender, __movable_value _Fun>
54 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
61 static_cast<_Sender&&>(__sndr))); in operator ()()
72 using _Sender = __1; typedef
77 get_env_t(_Sender&)),
78 _Sender, _Fun),
79 tag_invoke_t(upon_stopped_t, _Sender, _Fun)>;
85 []<class _Sender, class... _Env>(_Sender&&, _Env&&...) noexcept
86 -> __completion_signatures_t<__decay_t<__data_of<_Sender>>,
87 __child_of<_Sender>, _Env...> {
[all …]
H A D__upon_error.hpp53 template <sender _Sender, __movable_value _Fun>
54 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
61 static_cast<_Sender&&>(__sndr))); in operator ()()
71 using _Sender = __1; typedef
76 get_env_t(_Sender&)),
77 _Sender, _Fun),
78 tag_invoke_t(upon_error_t, _Sender, _Fun)>;
84 []<class _Sender, class... _Env>(_Sender&&, _Env&&...) noexcept
85 -> __completion_signatures_t<__decay_t<__data_of<_Sender>>,
86 __child_of<_Sender>, _Env...> {
[all …]
H A D__debug.hpp143 template <class _Sender>
168 using _Sender = stdexec::__t<_SenderId>; in __t() typedef
173 _SIGNAL_SENT_BY_SENDER_<__name_of<_Sender>>>; in __t()
234 template <class _Sigs, class _Env = empty_env, class _Sender>
235 void __debug_sender(_Sender&& __sndr, const _Env& = {}) in __debug_sender()
239 if (sizeof(_Sender) == ~0u)
242 __debug_receiver<__cvref_id<_Sender>, _Env, _Sigs>;
243 using _Operation = connect_result_t<_Sender, _Receiver>;
248 connect(static_cast<_Sender&&>(__sndr), _Receiver{});
255 template <class _Env = empty_env, class _Sender>
[all …]
H A D__basic_sender.hpp39 template <class _Sender>
40 using __impl_of = decltype((__declval<_Sender>().__impl_));
128 []<class _Sender>(_Sender&& __sndr, __ignore) noexcept -> decltype(auto) {
129 return __sndr.apply(static_cast<_Sender&&>(__sndr), __get_data());
133 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver __rcvr) //
134 noexcept(__nothrow_constructible_from<__op_state<_Sender, _Receiver>,
135 _Sender, _Receiver>)
136 -> __op_state<_Sender, _Receiver>
137 requires __connectable<_Sender, _Receiver>
139 return __op_state<_Sender, _Receiver>{static_cast<_Sender&&>(__sndr),
[all …]
H A D__into_variant.hpp42 template <class _Sender, class _Env>
43 requires sender_in<_Sender, _Env>
44 using __into_variant_result_t = value_types_of_t<_Sender, _Env>;
46 template <class _Sender, class... _Env>
48 __value_types_t<__completion_signatures_of_t<_Sender, _Env...>>;
55 template <class _Sender, class... _Env>
58 __completion_signatures_of_t<_Sender, _Env...>,
59 __meval<__variant_completions, __variant_t<_Sender, _Env...>>,
64 template <sender _Sender>
65 auto operator()(_Sender&& __sndr) const -> __well_formed_sender auto in operator ()()
[all …]
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp49 template <class _Sender, class _Env = empty_env>
51 sender_in<_Sender, _Env> //
53 __all_contained_in<completion_signatures_of_t<_Sender, _Env>,
83 template <class _Receiver, class _Sender>
86 stdexec::__declval<_Sender>()));
145 template <class _Sender>
147 requires { typename _Sender::sender_concept; } && //
148 stdexec::same_as<typename _Sender::sender_concept, sequence_sender_t>;
150 template <class _Sender>
152 __enable_sequence_sender<_Sender>;
[all …]

12