Home
last modified time | relevance | path

Searched refs:__receiver_t (Results 1 – 7 of 7) sorted by relevance

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__submit.hpp111 using __receiver_t = __receiver<__ref_t<__operation>>; typedef
115 connect_result_t<_Sender, __receiver_t> __op_state_;
120 connect(static_cast<_Sender&&>(__sndr), __receiver_t{__ref(*this)})) in __operation()
H A D__split.hpp72 using __receiver_t = typedef
79 __receiver_t<__child_of<_Sender>, __decay_t<__data_of<_Sender>>>; in transform_sender()
H A D__ensure_started.hpp80 using __receiver_t = typedef
87 __receiver_t<__child_of<_Sender>, __decay_t<__data_of<_Sender>>>; in transform_sender()
H A D__as_awaitable.hpp142 using __receiver_t = typedef
196 using __receiver = __receiver_t<_Sender, _Promise>;
209 sender_to<_Sender, __receiver_t<_Sender, _Promise>> && //
H A D__sync_wait.hpp151 using __receiver_t = __t<__sync_wait_result_impl<_Sender, __q<__receiver>>>; typedef
157 using __t = __receiver_t<_Sender>;
317 __receiver_t<_Sender>{&__local, &__result}); in apply_sender()
H A D__shared.hpp235 using __receiver_t = __t<__receiver<__cvref_id<_CvrefSender>, __id<_Env>>>; typedef
256 connect_result_t<_CvrefSender, __receiver_t> __shared_op_;
262 connect(static_cast<_CvrefSender&&>(__sndr), __receiver_t{this}))
H A D__basic_sender.hpp308 using __receiver_t = typedef
319 noexcept((__nothrow_connectable<_Child, __receiver_t<_Is>> && ...)) in operator ()()
320 -> __tuple_for<connect_result_t<_Child, __receiver_t<_Is>>...> in operator ()()
323 __receiver_t<_Is>{__op_})...}; in operator ()()