Home
last modified time | relevance | path

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

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__transform_sender.hpp58 decltype(auto) operator()(_Domain __dom, _Sender&& __sndr, in operator ()()
63 return __dom.transform_env(static_cast<_Sender&&>(__sndr), 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 ()()
227 auto dependent_domain::transform_sender(_Sender&& __sndr, in transform_sender() argument
233 transform_env(*this, static_cast<_Sender&&>(__sndr), __env); in transform_sender()
237 static_cast<_Sender&&>(__sndr), in transform_sender()
278 decltype(auto) operator()(_Domain __dom, _Tag, _Sender&& __sndr, in operator ()()
[all …]
H A D__sender_adaptor_closure.hpp63 operator()(_Sender&& __sndr) && in operator ()()
66 static_cast<_T0&&>(__t0_)(static_cast<_Sender&&>(__sndr))); in operator ()()
74 operator()(_Sender&& __sndr) const& in operator ()()
76 return __t1_(__t0_(static_cast<_Sender&&>(__sndr))); in operator ()()
87 operator|(_Sender&& __sndr, _Closure&& __clsur) in operator |() argument
89 return static_cast<_Closure&&>(__clsur)(static_cast<_Sender&&>(__sndr)); in operator |()
114 [&__sndr, this](_As&... __as) noexcept( in operator ()()
118 __fun_)(static_cast<_Sender&&>(__sndr), in operator ()()
127 auto operator()(_Sender&& __sndr) const& // in operator ()()
132 [&__sndr, this](const _As&... __as) noexcept( 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()
144 static_cast<_Sender&&>(__sndr)); in transform_sender()
148 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
161 static_cast<_Sender&&>(__sndr), __env); in transform_sender()
165 return static_cast<_Sender>(static_cast<_Sender&&>(__sndr)); in transform_sender()
180 static_cast<_Sender&&>(__sndr),
185 return _Tag().apply_sender(static_cast<_Sender&&>(__sndr),
191 auto transform_env(_Sender&& __sndr, in transform_env()
285 return __get_early_domain(__sndr); in operator ()()
306 auto operator()(const _Sender& __sndr, const _Env&) const noexcept in operator ()()
[all …]
H A D__on.hpp110 _Sender&& __sndr) const -> __well_formed_sender auto in operator ()()
112 auto __domain = __get_early_domain(__sndr); in operator ()()
115 static_cast<_Sender&&>(__sndr))); in operator ()()
120 auto operator()(_Sender&& __sndr, _Scheduler&& __sched, in operator ()()
123 auto __domain = __get_early_domain(__sndr); in operator ()()
128 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.hpp65 _Sender&& __sndr) const -> __well_formed_sender auto 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__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__split.hpp48 auto operator()(_Sender&& __sndr, 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__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()
316 auto __op_state = connect(static_cast<_Sender&&>(__sndr), in apply_sender()
342 auto operator()(_Sender&& __sndr) const -> decltype(auto) in operator ()()
351 auto __domain = __get_early_domain(__sndr); in operator ()()
353 static_cast<_Sender&&>(__sndr)); in operator ()()
374 auto apply_sender(_Sender&& __sndr) const in apply_sender()
378 sync_wait_t()(into_variant(static_cast<_Sender&&>(__sndr)))) in apply_sender()
H A D__continue_on.hpp55 auto operator()(_Sender&& __sndr, 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__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__senders.hpp303 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
309 auto __domain = __get_late_domain(__sndr, __env);
319 __domain, static_cast<_Sender&&>(__sndr), __env);
329 return transform_sender(__domain, static_cast<_Sender&&>(__sndr),
342 transform_sender(__domain, static_cast<_Sender&&>(__sndr),
349 transform_sender(__domain, static_cast<_Sender&&>(__sndr),
360 static_cast<_Sender&&>(__sndr), __env),
382 && requires(_Sender&& __sndr, _Receiver&& __rcvr) {
383 connect(static_cast<_Sender&&>(__sndr),
H A D__shared.hpp105 explicit __local_state(_CvrefSender&& __sndr) noexcept : in __local_state()
108 __sh_state_(__get_sh_state(__sndr))
169 static auto __get_sh_state(_CvrefSender& __sndr) noexcept in __get_sh_state()
171 return __sndr in __get_sh_state()
172 .apply(static_cast<_CvrefSender&&>(__sndr), __detail::__get_data()) in __get_sh_state()
258 explicit __shared_state(_CvrefSender&& __sndr, _Env __env) : in __shared_state()
262 connect(static_cast<_CvrefSender&&>(__sndr), __receiver_t{this}))
486 _CvrefSender&& __sndr,
490 static_cast<_CvrefSender&&>(__sndr)};
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_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__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_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__stopped_as_error.hpp35 auto operator()(_Sender&& __sndr, _Error __err) const in operator ()()
38 static_cast<_Sender&&>(__sndr), in operator ()()
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__let.hpp459 auto operator()(_Sender&& __sndr, _Fun __fun) const -> __well_formed_sender in operator ()()
462 auto __domain = __get_early_domain(__sndr); in operator ()()
466 static_cast<_Sender&&>(__sndr))); in operator ()()
486 static auto transform_env(_Sender&& __sndr, in transform_env()
489 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_env()
496 transform_sender(_Sender&& __sndr, const _Env& __env) -> decltype(auto) in transform_sender()
498 return __sexpr_apply(static_cast<_Sender&&>(__sndr), in transform_sender()
521 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver&) {
533 return __sndr.apply(
534 static_cast<_Sender&&>(__sndr),
H A D__basic_sender.hpp127 []<class _Sender>(_Sender&& __sndr, __ignore) noexcept -> decltype(auto) {
128 return __sndr.apply(static_cast<_Sender&&>(__sndr), __get_data());
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 {
238 __op_base(_Sexpr&& __sndr, _Receiver&& __rcvr) // in __op_base()
242 __state_(__sexpr_impl<__tag_t>::get_state(static_cast<_Sexpr&&>(__sndr), in __op_base()
549 static auto apply(_Sender&& __sndr, _ApplyFn&& __fun) // in apply()
555 return static_cast<_Sender&&>(__sndr).__impl_( in apply()
H A D__senders_core.hpp62 && requires(_Sender&& __sndr, _Env&&... __env) {
64 get_completion_signatures(static_cast<_Sender&&>(__sndr),
H A D__execute.hpp82 void apply_sender(_Sender&& __sndr, _Fun __fun) const noexcept(false) in apply_sender()
84 __submit(static_cast<_Sender&&>(__sndr), in apply_sender()
/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