Home
last modified time | relevance | path

Searched refs:__receiver (Results 1 – 11 of 11) sorted by relevance

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__as_awaitable.hpp91 struct __receiver struct
97 using __id = __receiver;
143 __t<__receiver<__id<_Promise>, __value_t<_Sender, _Promise>>>;
185 noexcept(__nothrow_connectable<_Sender, __receiver>) : in __t()
187 __receiver{{&this->__result_, __hcoro}})) in __t()
196 using __receiver = __receiver_t<_Sender, _Promise>; typedef
197 connect_result_t<_Sender, __receiver> __op_state_;
H A D__submit.hpp45 struct __receiver struct
48 using __t = __receiver; argument
49 using __id = __receiver; argument
111 using __receiver_t = __receiver<__ref_t<__operation>>;
H A D__schedule_from.hpp133 __tag(std::move(__state->__receiver()), in __make_visitor_fn()
160 stdexec::set_error(static_cast<_Receiver&&>(__state_->__receiver()), in set_error()
166 stdexec::set_stopped(static_cast<_Receiver&&>(__state_->__receiver())); in set_stopped()
171 return stdexec::get_env(__state_->__receiver()); in get_env()
H A D__shared.hpp143 stdexec::set_stopped(static_cast<_Receiver&&>(this->__receiver())); in operator ()()
164 auto __visitor = __make_notify_visitor(__self->__receiver()); in __notify()
184 struct __receiver struct
192 using __id = __receiver;
235 using __receiver_t = __t<__receiver<__cvref_id<_CvrefSender>, __id<_Env>>>;
H A D__sync_wait.hpp92 struct __receiver struct
97 using __id = __receiver;
151 using __receiver_t = __t<__sync_wait_result_impl<_Sender, __q<__receiver>>>;
H A D__receiver_adaptor.hpp35 struct __receiver : __nope struct
45 using __not_a_receiver = __no::__receiver;
H A D__basic_sender.hpp165 struct __receiver struct
173 using __id = __receiver;
288 auto __receiver() noexcept -> decltype(auto) in __receiver() function
309 __t<__receiver<__id<_Receiver>, _Sexpr, __msize_t<_Idx>>>;
H A D__split.hpp73 __t<__meval<__receiver, __cvref_id<_CvrefSender>, __id<_Env>>>;
H A D__ensure_started.hpp81 __t<__meval<__receiver, __cvref_id<_CvrefSender>, __id<_Env>>>;
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dat_coroutine_exit.hpp80 using __receiver = __t<__receiver_id<_Rec>>; typedef
98 requires sender_to<_Sender, __receiver<_Receiver>>
100 -> connect_result_t<_Sender, __receiver<_Receiver>> in connect()
104 __receiver<_Receiver>{static_cast<_Receiver&&>(__rcvr)}); in connect()
H A Dany_sender_of.hpp1071 __t(_Sender&& __sender, _Receiver&& __receiver) : in __t() argument
1072 __operation_base<_Receiver>{static_cast<_Receiver&&>(__receiver)}, in __t()
1103 __t(_Sender&& __sender, _Receiver&& __receiver) : in __t() argument
1104 __rec_{static_cast<_Receiver&&>(__receiver)}, in __t()
1178 [](void* __object_pointer, __receiver_ref_t __receiver) in STDEXEC_MEMFN_DECL()
1188 static_cast<__receiver_ref_t&&>(__receiver)); in STDEXEC_MEMFN_DECL()
1231 auto __connect(__receiver_ref_t __receiver) in __connect()
1236 static_cast<__receiver_ref_t&&>(__receiver)); in __connect()
1404 any_receiver_ref(_Receiver& __receiver) // in any_receiver_ref() argument
1407 __receiver_(__receiver) in any_receiver_ref()