Home
last modified time | relevance | path

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

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__domain.hpp67 && __has_transform_sender<tag_of_t<_Sender>, _Sender, _Env...>;
79 && __has_transform_env<tag_of_t<_Sender>, _Sender, _Env>;
87 template <class _Sender>
99 tag_of_t<_Sender>().transform_sender(__declval<_Sender>())); in __is_nothrow_transform_sender()
103 return __nothrow_constructible_from<_Sender, _Sender>; in __is_nothrow_transform_sender()
118 return __nothrow_constructible_from<_Sender, _Sender>; in __is_nothrow_transform_sender()
148 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
165 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
231 template <class _Sender>
235 template <class _Sender>
[all …]
H A D__sync_wait.hpp76 template <class _Sender>
80 template <class _Sender>
150 template <class _Sender>
154 template <class _Sender>
159 template <class _Sender>
162 template <class _Sender>
231 else if constexpr (!sender_to<_Sender, __sync_receiver_for_t<_Sender>>) in __diagnose_error()
257 sync_wait_t, __early_domain_of_t<_Sender>, _Sender>
268 template <class _Sender, class _Error = __error_description_t<_Sender>>
279 _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>
62 template <class _Sender, class... _Env>
68 template <class _Sender, class... _Env>
84 template <class _Sender>
88 template <class _Sender>
395 sender_in<_Sender, _Env> //
410 sender_in<_Sender, _Env> &&
419 template <class _Sender>
[all …]
H A D__sender_adaptor_closure.hpp41 template <class _Tp, class _Sender>
58 template <sender _Sender>
59 requires __callable<_T0, _Sender> &&
63 operator()(_Sender&& __sndr) && in operator ()()
69 template <sender _Sender>
74 operator()(_Sender&& __sndr) const& in operator ()()
84 template <sender _Sender, __sender_adaptor_closure_for<_Sender> _Closure>
86 __call_result_t<_Closure, _Sender>
107 template <sender _Sender>
111 _Sender&& __sndr) && noexcept(__nothrow_callable<_Fun, _Sender, _As...>) in operator ()()
[all …]
H A D__transform_sender.hpp39 template <class _Sender, class _Env>
42 template <sender_expr _Sender, class _Env>
55 template <class _Domain, class _Sender, class _Env>
76 template <class _Domain, class _Sender, class... _Env>
185 template <class _Domain, class _Sender, class... _Env>
194 template <class _Sender, class _Env>
199 _Sender, _Env>; in __is_nothrow_transform_sender()
225 template <sender_expr _Sender, class _Env>
237 static_cast<_Sender&&>(__sndr), in transform_sender()
290 _Tag(), static_cast<_Sender&&>(__sndr), in operator ()()
[all …]
H A D__sender_introspection.hpp64 template <class _Sender>
73 template <class _Sender, class _ApplyFn>
77 template <class _Sender>
80 template <class _Sender>
87 template <class _Ny, class _Sender>
94 template <class _Sender>
97 template <class _Sender>
109 template <class _Sender>
111 __mvalid<tag_of_t, _Sender>;
113 template <class _Sender, class _Tag>
[all …]
H A D__senders_core.hpp40 template <class _Sender>
44 || __awaitable<_Sender, __env::__promise<empty_env>>;
47 template <class _Sender>
50 template <class _Sender>
52 enable_sender<__decay_t<_Sender>> //
53 && environment_provider<__cref_t<_Sender>> //
54 && __detail::__consistent_completion_domains<_Sender> //
56 && constructible_from<__decay_t<_Sender>, _Sender>;
58 template <class _Sender, class... _Env>
61 && sender<_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>>
53 return static_cast<_Sender&&>(__sndr);
71 using _Sender = __1; typedef
76 _Sender),
77 tag_invoke_t(ensure_started_t, _Sender)>;
83 template <class _Sender>
84 static auto transform_sender(_Sender&& __sndr) in transform_sender()
87 __receiver_t<__child_of<_Sender>, __decay_t<__data_of<_Sender>>>; in transform_sender()
91 static_cast<_Sender&&>(__sndr), in transform_sender()
[all …]
H A D__start_detached.hpp71 template <sender_in<__root_env> _Sender>
73 start_detached_t, _Sender>
74 void operator()(_Sender&& __sndr) const in operator ()()
84 void operator()(_Sender&& __sndr, _Env&& __env) const in operator ()()
91 using _Sender = __0; typedef
95 get_env_t(const _Sender&)),
96 _Sender),
97 tag_invoke_t(start_detached_t, _Sender)>;
99 template <class _Sender, class _Env = __root_env>
100 requires sender_to<_Sender, __detached_receiver_t<_Env>>
[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, in operator ()()
63 using _Sender = __1; typedef
68 _Sender),
69 tag_invoke_t(split_t, _Sender)>;
75 template <class _Sender>
76 static auto transform_sender(_Sender&& __sndr) in transform_sender()
79 __receiver_t<__child_of<_Sender>, __decay_t<__data_of<_Sender>>>; in transform_sender()
83 static_cast<_Sender&&>(__sndr), in transform_sender()
[all …]
H A D__transform_completion_signatures.hpp38 template <class _Sender, class... _Env>
46 template <class _Sender, class... _Env>
47 requires sender_in<_Sender, _Env...>
52 template <class _Sender, class... _Env>
53 requires sender_in<_Sender, _Env...>
434 template <class _Sender, class... _Env>
436 sender_in<_Sender, _Env...> && __sends<set_stopped_t, _Sender, _Env...>;
438 template <class _Sender, class... _Env>
443 template <class _Sender, class... _Env>
445 sender_in<_Sender, _Env...> && //
[all …]
H A D__continue_on.hpp47 template <class _Sender>
50 __child_of<_Sender>>;
54 template <sender _Sender, scheduler _Scheduler>
55 auto operator()(_Sender&& __sndr, 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,
97 template <class _Sender, class _Env>
[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>
65 _Sender&& __sndr) const -> __well_formed_sender auto 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__on.hpp60 template <class _Sender, class _Env>
108 template <scheduler _Scheduler, sender _Sender>
118 template <sender _Sender, scheduler _Scheduler,
119 __sender_adaptor_closure_for<_Sender> _Closure>
120 auto operator()(_Sender&& __sndr, _Scheduler&& __sched, in operator ()()
128 static_cast<_Sender&&>(__sndr))); in operator ()()
220 template <class _Sender, class _Env>
228 template <class _Sender, class _Env>
237 return __no_scheduler_in_environment<_Sender, _Env>{}; in transform_sender()
241 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
[all …]
H A D__bulk.hpp82 auto operator()(_Sender&& __sndr, _Shape __shape, 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>
120 template <class _Sender>
124 []<class _Sender, class... _Env>(_Sender&&, _Env&&...) noexcept
125 -> __completion_signatures<__fun_t<_Sender>, __shape_t<_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__when_all.hpp79 template <class _Sender, class _Env>
81 sender_in<_Sender, _Env> && __mvalid<__value_types_of_t, _Sender, _Env,
120 _Sender, _Env...>;
122 template <class _Sender>
275 using _Sender = __1; typedef
446 using _Sender = __1; typedef
491 []<class _Sender>(_Sender&&) noexcept //
501 using _Sender = __1; typedef
546 []<class _Sender>(_Sender&&) noexcept //
556 using _Sender = __1; typedef
[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__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__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>;
255 template <class _Env = empty_env, class _Sender>
256 void __debug_sender(_Sender&& __sndr, const _Env& = {}) in __debug_sender()
[all …]
H A D__basic_sender.hpp38 template <class _Sender>
127 []<class _Sender>(_Sender&& __sndr, __ignore) noexcept -> decltype(auto) {
132 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver __rcvr) //
138 return __op_state<_Sender, _Receiver>{static_cast<_Sender&&>(__sndr),
158 []<class _Sender>(_Sender&& __sndr, __ignore = {}) noexcept {
623 template <class _Sender>
624 extern __mcompose<__cplr, __name_of_fn<_Sender>> __name_of_v<_Sender&>;
626 template <class _Sender>
627 extern __mcompose<__cprr, __name_of_fn<_Sender>> __name_of_v<_Sender&&>;
629 template <class _Sender>
[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 …]
H A D__as_awaitable.hpp136 template <class _Sender, class _Promise>
141 template <class _Sender, class _Promise>
179 using _Sender = stdexec::__t<_SenderId>; typedef
180 using __value = __value_t<_Sender, _Promise>;
186 __op_state_(connect(static_cast<_Sender&&>(sndr), in __t()
196 using __receiver = __receiver_t<_Sender, _Promise>;
197 connect_result_t<_Sender, __receiver> __op_state_;
201 template <class _Promise, class _Sender>
203 __t<__sender_awaitable<__id<_Promise>, __id<_Sender>>>;
205 template <class _Sender, class _Promise>
[all …]
H A D__let.hpp159 template <class _Sender, class _Set, class... _Env>
179 template <class _Sender, class... _Env>
181 sender_in<_Sender, _Env...> || (sender<_Sender> && (sizeof...(_Env) == 0));
226 template <class _Sender, class _Receiver>
268 template <class _Sender, class _Set>
476 using _Sender = __1; typedef
486 static auto transform_env(_Sender&& __sndr, in transform_env()
521 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver&) {
523 using _Fun = __data_of<_Sender>;
524 using _Child = __child_of<_Sender>;
[all …]
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp51 sender_in<_Sender, _Env> //
86 stdexec::__declval<_Sender>()));
145 template <class _Sender>
150 template <class _Sender>
152 __enable_sequence_sender<_Sender>;
166 template <class _Sender, class _Env>
168 transform_sender_result_t<__late_domain_of_t<_Sender, _Env>, _Sender, _Env>;
170 template <class _Sender, class _Env>
173 template <class _Sender, class _Env>
177 template <class _Sender, class _Env>
[all …]

12