Home
last modified time | relevance | path

Searched refs:__sndr (Results 1 – 25 of 37) sorted by relevance

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__sender_adaptor_closure.hpp63 _Sender&& __sndr) && in operator ()()
66 static_cast<_T0&&>(__t0_)(static_cast<_Sender&&>(__sndr))); in operator ()()
74 _Sender&& __sndr) const& in operator ()()
76 return __t1_(__t0_(static_cast<_Sender&&>(__sndr))); in operator ()()
86 __call_result_t<_Closure, _Sender> operator|(_Sender&& __sndr, in operator |() argument
89 return static_cast<_Closure&&>(__clsur)(static_cast<_Sender&&>(__sndr)); in operator |()
146 auto operator()(_Sender&& __sndr) && // in operator ()()
151 return this->apply(__lambda_rvalue<_Sender>{*this, __sndr}, *this); in operator ()()
154 [&__sndr, this](_As&... __as) // in operator ()()
158 __fun_)(static_cast<_Sender&&>(__sndr), in operator ()()
[all …]
H A D__transform_sender.hpp45 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const
58 decltype(auto) operator()(_Domain __dom, _Sender&& __sndr, in operator ()()
63 return __dom.transform_env(static_cast<_Sender&&>(__sndr), in operator ()()
69 static_cast<_Sender&&>(__sndr), static_cast<_Env&&>(__env)); in operator ()()
97 decltype(auto) operator()(_Domain __dom, _Sender&& __sndr, in operator ()()
104 return __dom.transform_sender(static_cast<_Sender&&>(__sndr), in operator ()()
110 static_cast<_Sender&&>(__sndr), __env...); in operator ()()
124 decltype(auto) operator()(_Domain __dom, _Sender&& __sndr, in operator ()()
135 return __transform_sender_1()(__dom, static_cast<_Sender&&>(__sndr), in operator ()()
144 __dom, static_cast<_Sender&&>(__sndr), __env...), in operator ()()
[all …]
H A D__start_detached.hpp74 void operator()(_Sender&& __sndr) const in operator ()()
76 auto __domain = __get_early_domain(__sndr); in operator ()()
77 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr)); in operator ()()
84 void operator()(_Sender&& __sndr, _Env&& __env) const in operator ()()
86 auto __domain = __get_late_domain(__sndr, __env); in operator ()()
87 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr), in operator ()()
101 void apply_sender(_Sender&& __sndr, _Env&& __env = {}) const in apply_sender()
103 __submit(static_cast<_Sender&&>(__sndr),
H A D__domain.hpp130 decltype(auto) transform_sender(_Sender&& __sndr) const in transform_sender()
138 return stdexec::__sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
144 static_cast<_Sender&&>(__sndr)); in transform_sender()
148 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
155 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const in transform_sender()
161 static_cast<_Sender&&>(__sndr), __env); in transform_sender()
165 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
173 decltype(auto) apply_sender(_Tag, _Sender&& __sndr, _Args&&... __args) const
180 static_cast<_Sender&&>(__sndr),
185 return _Tag().apply_sender(static_cast<_Sender&&>(__sndr),
[all …]
H A D__on.hpp108 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
111 auto __domain = __get_early_domain(__sndr); in operator ()()
114 static_cast<_Sender&&>(__sndr))); in operator ()()
119 auto operator()(_Sender&& __sndr, _Scheduler&& __sched, in operator ()()
122 auto __domain = __get_early_domain(__sndr); in operator ()()
127 static_cast<_Sender&&>(__sndr))); in operator ()()
222 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
224 return __sexpr_apply(__sndr, in transform_env()
230 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
241 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__sender_introspection.hpp29 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 ()()
H A D__start_on.hpp64 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
71 static_cast<_Sender&&>(__sndr))); in operator ()()
84 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
86 return __sexpr_apply(__sndr, in transform_env()
91 static auto transform_sender(_Sender&& __sndr, const _Env&) in transform_sender()
94 static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__starts_on.hpp65 auto operator()(_Scheduler&& __sched, _Sender&& __sndr) const in operator ()()
72 static_cast<_Sender&&>(__sndr))); in operator ()()
85 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
87 return __sexpr_apply(__sndr, in transform_env()
92 static auto transform_sender(_Sender&& __sndr, const _Env&) in transform_sender()
95 static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__ensure_started.hpp48 [[nodiscard]] auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
53 return static_cast<_Sender&&>(__sndr);
57 auto __domain = __get_late_domain(__sndr, __env);
61 static_cast<_Sender&&>(__sndr)));
84 static auto transform_sender(_Sender&& __sndr) in transform_sender()
91 static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__sync_wait.hpp258 auto operator()(_Sender&& __sndr) const in operator ()()
261 auto __domain = __get_early_domain(__sndr); in operator ()()
263 static_cast<_Sender&&>(__sndr)); in operator ()()
308 auto apply_sender(_Sender&& __sndr) const in apply_sender()
317 connect(static_cast<_Sender&&>(__sndr), in apply_sender()
343 auto operator()(_Sender&& __sndr) const -> decltype(auto) in operator ()()
352 auto __domain = __get_early_domain(__sndr); in operator ()()
354 static_cast<_Sender&&>(__sndr)); in operator ()()
375 auto apply_sender(_Sender&& __sndr) const in apply_sender()
379 sync_wait_t()(into_variant(static_cast<_Sender&&>(__sndr)))) in apply_sender()
H A D__split.hpp48 auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
51 auto __domain = __get_late_domain(__sndr, __env);
54 static_cast<_Sender&&>(__sndr)));
76 static auto transform_sender(_Sender&& __sndr) in transform_sender()
83 static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__continues_on.hpp55 auto operator()(_Sender&& __sndr, _Scheduler&& __sched) const in operator ()()
58 auto __domain = __get_early_domain(__sndr); in operator ()()
63 static_cast<_Sender&&>(__sndr))); in operator ()()
98 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
100 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__continue_on.hpp55 auto operator()(_Sender&& __sndr, _Scheduler&& __sched) const in operator ()()
58 auto __domain = __get_early_domain(__sndr); in operator ()()
63 static_cast<_Sender&&>(__sndr))); in operator ()()
98 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
100 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
H A D__senders.hpp302 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
308 auto __domain = __get_late_domain(__sndr, __env);
318 __domain, static_cast<_Sender&&>(__sndr), __env);
328 return transform_sender(__domain, static_cast<_Sender&&>(__sndr),
341 transform_sender(__domain, static_cast<_Sender&&>(__sndr),
348 transform_sender(__domain, static_cast<_Sender&&>(__sndr),
359 static_cast<_Sender&&>(__sndr), __env),
381 && requires(_Sender&& __sndr, _Receiver&& __rcvr) {
382 connect(static_cast<_Sender&&>(__sndr),
H A D__shared.hpp106 explicit __local_state(_CvrefSender&& __sndr) noexcept : in __local_state()
109 __sh_state_(__get_sh_state(__sndr))
170 static auto __get_sh_state(_CvrefSender& __sndr) noexcept in __get_sh_state()
172 return __sndr in __get_sh_state()
173 .apply(static_cast<_CvrefSender&&>(__sndr), __detail::__get_data()) in __get_sh_state()
260 explicit __shared_state(_CvrefSender&& __sndr, _Env __env) : in __shared_state()
264 connect(static_cast<_CvrefSender&&>(__sndr), __receiver_t{this}))
488 _CvrefSender&& __sndr,
492 static_cast<_CvrefSender&&>(__sndr)};
H A D__submit.hpp117 __operation(_Sender&& __sndr, _Receiver __rcvr) : in __operation()
120 connect(static_cast<_Sender&&>(__sndr), __receiver_t{__ref(*this)})) in __operation()
127 void operator()(_Sender&& __sndr, _Receiver __rcvr) const noexcept(false) in operator ()()
143 __op_alloc, __op, static_cast<_Sender&&>(__sndr), in operator ()()
157 static_cast<_Sender&&>(__sndr), in operator ()()
H A D__basic_sender.hpp128 []<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) //
139 return __op_state<_Sender, _Receiver>{static_cast<_Sender&&>(__sndr),
159 []<class _Sender>(_Sender&& __sndr, __ignore = {}) noexcept {
261 __state_box(_Sexpr&& __sndr, _Receiver& __rcvr) // in __state_box()
264 __state_(__sexpr_impl<__tag_t>::get_state(static_cast<_Sexpr&&>(__sndr), in __state_box()
303 __op_base(_Sexpr&& __sndr, _Receiver&& __rcvr) // in __op_base()
308 __state_(__sexpr_impl<__tag_t>::get_state(static_cast<_Sexpr&&>(__sndr), in __op_base()
336 __op_base(_Sexpr&& __sndr, _Receiver&& __rcvr) // in __op_base()
[all …]
H A D__then.hpp53 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
56 auto __domain = __get_early_domain(__sndr); in operator ()()
59 static_cast<_Sender&&>(__sndr))); in operator ()()
H A D__upon_stopped.hpp54 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
57 auto __domain = __get_early_domain(__sndr); in operator ()()
61 static_cast<_Sender&&>(__sndr))); in operator ()()
H A D__into_variant.hpp65 auto operator()(_Sender&& __sndr) const -> __well_formed_sender auto in operator ()()
67 auto __domain = __get_early_domain(__sndr); in operator ()()
70 __make_sexpr<into_variant_t>(__(), static_cast<_Sender&&>(__sndr))); in operator ()()
H A D__upon_error.hpp54 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
57 auto __domain = __get_early_domain(__sndr); in operator ()()
61 static_cast<_Sender&&>(__sndr))); in operator ()()
H A D__let.hpp473 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
476 auto __domain = __get_early_domain(__sndr); in operator ()()
480 static_cast<_Sender&&>(__sndr))); in operator ()()
500 static auto transform_env(_Sender&& __sndr, const _Env& __env) in transform_env()
503 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_env()
509 static auto transform_sender(_Sender&& __sndr, const _Env& __env) in transform_sender()
512 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
535 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver&) {
547 return __sndr.apply(
548 static_cast<_Sender&&>(__sndr),
H A D__debug.hpp235 void __debug_sender(_Sender&& __sndr, const _Env& = {}) in __debug_sender() argument
248 connect(static_cast<_Sender&&>(__sndr), _Receiver{});
256 void __debug_sender(_Sender&& __sndr, const _Env& = {}) in __debug_sender() argument
273 connect(static_cast<_Sender&&>(__sndr), _Receiver{});
H A D__stopped_as_error.hpp35 auto operator()(_Sender&& __sndr, _Error __err) const in operator ()()
38 static_cast<_Sender&&>(__sndr), in operator ()()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp249 requires(_Sender&& __sndr, _Env&&... __env) {
250 get_item_types(static_cast<_Sender&&>(__sndr),
420 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
426 auto __domain = __get_late_domain(__sndr, __env);
437 __domain, static_cast<_Sender&&>(__sndr), __env));
453 transform_sender(__domain, static_cast<_Sender&&>(__sndr),
465 static_cast<_Sender&&>(__sndr), __env),
472 __domain, static_cast<_Sender&&>(__sndr), __env));
501 requires(_Sender&& __sndr, _Receiver&& __rcvr) {
502 subscribe(static_cast<_Sender&&>(__sndr),

12