Home
last modified time | relevance | path

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

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__receivers.hpp40 friend auto tag_invoke(_Self, _Receiver&& __rcvr, _As&&... __as) noexcept in tag_invoke() argument
41 -> decltype(static_cast<_Receiver&&>(__rcvr).set_value( in tag_invoke()
44 static_assert(noexcept(static_cast<_Receiver&&>(__rcvr).set_value( in tag_invoke()
48 __same_as<decltype(static_cast<_Receiver&&>(__rcvr).set_value( in tag_invoke()
52 static_cast<_Receiver&&>(__rcvr).set_value(static_cast<_As&&>(__as)...); in tag_invoke()
58 void operator()(_Receiver&& __rcvr, _As&&... __as) const noexcept in operator ()()
62 static_cast<_Receiver&&>(__rcvr), in operator ()()
75 friend auto tag_invoke(_Self, _Receiver&& __rcvr, _Error&& __err) noexcept in tag_invoke() argument
76 -> decltype(static_cast<_Receiver&&>(__rcvr).set_error( in tag_invoke()
79 static_assert(noexcept(static_cast<_Receiver&&>(__rcvr).set_error( in tag_invoke()
[all …]
H A D__basic_sender.hpp124 []<class _Receiver>(__ignore, __ignore, const _Receiver& __rcvr) noexcept
125 -> env_of_t<const _Receiver&> { return stdexec::get_env(__rcvr); };
133 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver __rcvr) //
140 static_cast<_Receiver&&>(__rcvr)};
151 _Index, __ignore, _Receiver& __rcvr, _SetTag,
155 _SetTag()(std::move(__rcvr), static_cast<_Args&&>(__args)...);
243 auto __rcvr() & noexcept -> _Receiver& in __rcvr() function
249 auto __rcvr() const& noexcept -> const _Receiver& in __rcvr() function
261 __state_box(_Sexpr&& __sndr, _Receiver& __rcvr) // in __state_box()
265 __rcvr)) in __state_box()
[all …]
H A D__connect_awaitable.hpp121 __t(auto&&, _Receiver&& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
123 explicit __t(auto&, _Receiver& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
212 __co_impl(_Awaitable __awaitable, _Receiver __rcvr) in __co_impl()
222 static_cast<_Receiver&&>(__rcvr))); in __co_impl()
225 set_value, static_cast<_Receiver&&>(__rcvr), in __co_impl()
232 co_await __co_call(set_error, static_cast<_Receiver&&>(__rcvr), in __co_impl()
247 auto operator()(_Awaitable&& __awaitable, _Receiver __rcvr) const in operator ()()
251 static_cast<_Receiver&&>(__rcvr)); in operator ()()
H A D__when_all.hpp151 auto __complete_fn(_Tag, _Receiver& __rcvr) noexcept in __complete_fn() argument
154 _Tag()(static_cast<_Receiver&&>(__rcvr), static_cast<_Ts&&>(__ts)...); in __complete_fn()
159 void __set_values(_Receiver& __rcvr, _ValuesTuple& __values) noexcept in __set_values() argument
163 __tup::__cat_apply(__when_all::__complete_fn(set_value, __rcvr), in __set_values()
207 void __arrive(_Receiver& __rcvr) noexcept in __arrive()
211 __complete(__rcvr); in __arrive()
216 void __complete(_Receiver& __rcvr) noexcept in __complete()
227 __when_all::__set_values(__rcvr, __values_); in __complete()
234 __errors_.visit(__complete_fn(set_error, __rcvr), in __complete()
239 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __complete()
[all …]
H A D__run_loop.hpp72 auto& __rcvr = static_cast<__t*>(__p)->__rcvr_; in __execute_impl() local
75 if (stdexec::get_stop_token(stdexec::get_env(__rcvr)) in __execute_impl()
78 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
82 stdexec::set_value(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
87 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __execute_impl()
94 __t(__task* __next, run_loop* __loop, _Receiver __rcvr) : in __t()
96 __rcvr_{static_cast<_Receiver&&>(__rcvr)}
128 auto connect(_Receiver __rcvr) const -> __operation<_Receiver> in connect()
131 static_cast<_Receiver&&>(__rcvr)}; in connect()
H A D__stopped_as_optional.hpp88 __ignore, _State&, _Receiver& __rcvr, _Tag,
95 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
101 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
107 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
112 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
H A D__submit.hpp117 __operation(_Sender&& __sndr, _Receiver __rcvr) : in __operation()
118 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __operation()
127 void operator()(_Sender&& __sndr, _Receiver __rcvr) const noexcept(false) in operator ()()
131 auto&& __env = get_env(__rcvr); in operator ()()
144 static_cast<_Receiver&&>(__rcvr)); in operator ()()
158 static_cast<_Receiver&&>(__rcvr)}) in operator ()()
H A D__read_env.hpp106 _Receiver& __rcvr) noexcept -> void {
113 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
114 __query(), stdexec::get_env(__rcvr));
123 return __query()(stdexec::get_env(__rcvr)); in __anona47160310102()
127 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
H A D__senders.hpp302 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
307 auto&& __env = get_env(__rcvr);
320 static_cast<_Receiver&&>(__rcvr));
330 .connect(static_cast<_Receiver&&>(__rcvr));
343 static_cast<_Receiver&&>(__rcvr));
350 static_cast<_Receiver&&>(__rcvr));
360 static_cast<_Receiver&&>(__rcvr));
381 && requires(_Sender&& __sndr, _Receiver&& __rcvr) {
383 static_cast<_Receiver&&>(__rcvr));
H A D__into_variant.hpp91 __ignore, _State, _Receiver& __rcvr, _Tag,
98 set_value(static_cast<_Receiver&&>(__rcvr),
104 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
110 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__bulk.hpp137 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
150 _Tag()(static_cast<_Receiver&&>(__rcvr),
161 _Tag()(static_cast<_Receiver&&>(__rcvr),
166 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
173 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__then.hpp91 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
95 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
101 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__upon_stopped.hpp94 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
98 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
104 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__upon_error.hpp93 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
97 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
103 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__inline_scheduler.hpp82 []<class _Receiver>(__ignore, _Receiver& __rcvr) noexcept -> void {
83 stdexec::set_value(static_cast<_Receiver&&>(__rcvr));
H A D__let.hpp425 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver() local
428 return static_cast<_Receiver&&>(__rcvr); in __get_result_receiver()
432 return __receiver_with_sched{static_cast<_Receiver&&>(__rcvr), in __get_result_receiver()
438 auto __get_env(const _Receiver& __rcvr) const noexcept -> __env_t in __get_env()
442 return stdexec::get_env(__rcvr); in __get_env()
448 __env::__without(stdexec::get_env(__rcvr), get_domain)); in __get_env()
590 _Receiver& __rcvr = __op_state.__rcvr_; in __bind() local
608 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __bind()
H A D__shared.hpp67 auto __make_notify_visitor(_Receiver& __rcvr) noexcept in __make_notify_visitor() argument
72 __tag(static_cast<_Receiver&&>(__rcvr), in __make_notify_visitor()
505 _Receiver& __rcvr) noexcept -> void {
518 const auto __stok = stdexec::get_stop_token(stdexec::get_env(__rcvr));
541 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr));
H A D__write_env.hpp70 [](__ignore, const auto& __state, const auto& __rcvr) noexcept { in __anon164445800202()
71 return __env::__join(__state, stdexec::get_env(__rcvr)); in __anon164445800202()
H A D__just.hpp48 _Receiver& __rcvr) noexcept -> void {
51 __tag_t()(static_cast<_Receiver&&>(__rcvr),
H A D__schedule_from.hpp247 __ignore, _State& __state, _Receiver& __rcvr, _Tag __tag,
265 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp67 auto operator()(_Receiver& __rcvr, _Item&& __item) const in operator ()()
75 return tag_invoke(*this, __rcvr, static_cast<_Item&&>(__item)); in operator ()()
420 auto operator()(_Sender&& __sndr, _Receiver&& __rcvr) const
425 auto&& __env = get_env(__rcvr);
436 __rcvr, transform_sender(
441 static_cast<_Receiver&&>(__rcvr)});
455 static_cast<_Receiver&&>(__rcvr));
466 static_cast<_Receiver&&>(__rcvr));
471 __rcvr, transform_sender(
477 static_cast<_Receiver&&>(__rcvr)});
[all …]
H A Dasync_scope.hpp83 _Receiver __rcvr) : in __t()
86 static_cast<_Receiver&&>(__rcvr)))
131 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
136 static_cast<_Receiver&&>(__rcvr)}; in connect()
257 explicit __t(const __impl* __scope, _Sender&& __c, _Rcvr&& __rcvr) : in __t()
259 {}, __scope, static_cast<_Rcvr&&>(__rcvr)}, in __t()
301 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) in connect()
306 static_cast<_Receiver&&>(__rcvr)}; in connect()
452 explicit __t(_Receiver2&& __rcvr, in __t() argument
458 __rcvr_(static_cast<_Receiver2&&>(__rcvr)),
[all …]
H A Dany_sender_of.hpp56 auto operator()(_Tag, void* __rcvr, _As&&... __as) const -> _Ret in operator ()()
58 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
67 auto operator()(_Tag, void* __rcvr, _As&&... __as) const -> _Ret in operator ()()
69 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
78 auto operator()(_Tag, void* __rcvr, _As&&... __as) const noexcept -> _Ret in operator ()()
80 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
89 auto operator()(_Tag, void* __rcvr, _As&&... __as) const noexcept -> _Ret in operator ()()
91 return __fn_(__rcvr, static_cast<_As&&>(__as)...); in operator ()()
823 __ref(_Rcvr& __rcvr) noexcept : in __ref()
825 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
[all …]
H A Denv.hpp145 static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
151 static_cast<_Receiver&&>(__rcvr)}; in connect()
H A Dat_coroutine_exit.hpp99 auto connect(_Receiver __rcvr) && noexcept in connect()
104 __receiver<_Receiver>{static_cast<_Receiver&&>(__rcvr)}); in connect()