Home
last modified time | relevance | path

Searched refs:__op_state (Results 1 – 4 of 4) sorted by relevance

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__let.hpp80 [](auto& __op_state) noexcept -> decltype(auto) {
81 return (__op_state.__rcvr_);
85 [](auto& __op_state) noexcept -> decltype(auto) {
86 return __op_state.__state_.__get_env(__op_state.__rcvr_);
413 auto __get_result_receiver(const _ResultSender&, _OpState& __op_state) in __get_result_receiver()
420 return __receiver_ref{__op_state, __let::__get_env, in __get_result_receiver()
425 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver()
562 static void __bind_(_State& __state, _OpState& __op_state, _As&&... __as) in __bind_()
571 auto __rcvr2 = __state.__get_result_receiver(__sndr2, __op_state); in __bind_()
579 static void __bind(_OpState& __op_state, _As&&... __as) noexcept in __bind()
[all …]
H A D__receiver_ref.hpp62 _Env (*__do_get_env)(const void* __op_state) noexcept;
67 auto* __op_state = static_cast<const _OpState*>(__ptr); in __s_get_env() local
68 return _GetEnv()(*__op_state); in __s_get_env()
81 auto __get_env(const void* __op_state) const noexcept -> _Env in __get_env()
83 return __do_get_env(__op_state); in __get_env()
101 __receiver_ref(_OpState& __op_state, _GetEnv, _GetReceiver = {}) noexcept : in __receiver_ref() argument
104 __op_state_{&__op_state}
H A D__basic_sender.hpp79 struct __op_state;
134 noexcept(__nothrow_constructible_from<__op_state<_Sender, _Receiver>,
136 -> __op_state<_Sender, _Receiver>
139 return __op_state<_Sender, _Receiver>{static_cast<_Sender&&>(__sndr),
175 using __parent_op_t = __op_state<_Sexpr, _Receiver>;
377 __op_state<_Sexpr, _Receiver>* __op_;
381 __op_state<_Sexpr, _Receiver>* __op_;
410 struct __op_state : __op_base<_Sexpr, _Receiver> struct
416 using __state_t = typename __op_state::__state_t; argument
429 __op_state(_Sexpr&& __sexpr, _Receiver __rcvr) // in __op_state() argument
[all …]
H A D__sync_wait.hpp316 auto __op_state = in apply_sender() local
319 stdexec::start(__op_state); in apply_sender()