Home
last modified time | relevance | path

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

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__receivers.hpp55 template <class _Receiver, class... _As>
91 template <class _Receiver, class _Error>
123 template <class _Receiver>
149 template <class _Receiver>
158 template <class _Receiver>
162 template <class _Receiver>
167 && constructible_from<__decay_t<_Receiver>, _Receiver>;
180 template <class _Receiver, class... _Sigs>
189 receiver<_Receiver> && //
196 template <class _Receiver, class _Sender>
[all …]
H A D__senders.hpp191 template <class _Sender, class _Receiver>
196 template <class _Sender, class _Receiver>
200 template <class _Sender, class _Receiver>
205 template <class _Sender, class _Receiver>
208 template <class _Sender, class _Receiver>
212 template <class _Sender, class _Receiver>
215 template <class _Sender, class _Receiver>
237 template <class _Sender, class _Receiver>
290 template <class _Sender, class _Receiver>
297 _Receiver> ||
[all …]
H A D__connect_awaitable.hpp114 using _Receiver = stdexec::__t<_ReceiverId>; typedef
160 _Receiver& __rcvr_;
164 template <receiver _Receiver>
165 using __promise_t = __t<__promise<__id<_Receiver>>>;
167 template <receiver _Receiver>
203 template <class _Awaitable, class _Receiver>
209 _Receiver __rcvr) -> __operation_t<_Receiver> in __co_impl()
232 template <receiver _Receiver, class _Awaitable>
241 template <class _Receiver, __awaitable<__promise_t<_Receiver>> _Awaitable>
242 requires receiver_of<_Receiver, __completions_t<_Receiver, _Awaitable>>
[all …]
H A D__basic_sender.hpp77 template <class _Sexpr, class _Receiver>
80 template <class _Sexpr, class _Receiver>
91 _Receiver&>;
93 template <class _Sexpr, class _Receiver>
123 []<class _Receiver>(__ignore, __ignore, const _Receiver& __rcvr) noexcept
132 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver __rcvr) //
135 -> __op_state<_Sender, _Receiver>
229 template <class _Sexpr, class _Receiver>
283 template <class _Sexpr, class _Receiver>
304 template <class _Sexpr, class _Receiver>
[all …]
H A D__submit.hpp59 if constexpr (__callable<get_allocator_t, env_of_t<_Receiver>>) in __delete_op()
100 auto get_env() const noexcept -> env_of_t<_Receiver&> in get_env()
110 using _Receiver = stdexec::__t<_ReceiverId>; typedef
114 _Receiver __rcvr_;
117 __operation(_Sender&& __sndr, _Receiver __rcvr) : in __operation()
118 __rcvr_(static_cast<_Receiver&&>(__rcvr)), in __operation()
126 template <receiver _Receiver, sender_to<_Receiver> _Sender>
134 using _Op = __operation<__id<_Sender>, __id<_Receiver>>; in operator ()()
144 static_cast<_Receiver&&>(__rcvr)); in operator ()()
156 start((new __operation<__id<_Sender>, __id<_Receiver>>{ in operator ()()
[all …]
H A D__let.hpp107 template <class _Receiver, class _Scheduler>
111 _Receiver __rcvr_;
141 template <class _Receiver, class _Scheduler>
142 __receiver_with_sched(_Receiver, _Scheduler)
143 -> __receiver_with_sched<_Receiver, _Scheduler>;
206 template <class _Receiver, class _Scheduler>
226 template <class _Sender, class _Receiver>
390 _Sched, _Receiver>;
419 _Receiver& __rcvr = __op_state.__rcvr_; in __get_result_receiver()
521 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver&) {
[all …]
H A D__run_loop.hpp60 using _Receiver = stdexec::__t<_ReceiverId>; typedef
68 _Receiver __rcvr_;
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)}
123 template <class _Receiver>
125 stdexec::__t<__operation<stdexec::__id<_Receiver>>>;
127 template <class _Receiver>
128 auto connect(_Receiver __rcvr) const -> __operation<_Receiver> in connect()
131 static_cast<_Receiver&&>(__rcvr)}; in connect()
[all …]
H A D__stopped_as_optional.hpp77 []<class _Self, class _Receiver>(_Self&&, _Receiver&) noexcept
78 requires __single_value_sender<__child_of<_Self>, env_of_t<_Receiver>>
82 __single_sender_value_t<__child_of<_Self>, env_of_t<_Receiver>>>;
87 []<class _State, class _Receiver, class _Tag, class... _Args>(
88 __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__schedule_from.hpp116 template <class _Scheduler, class _Sexpr, class _Receiver>
146 template <class _Scheduler, class _Sexpr, class _Receiver>
169 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env()
174 __state<_Scheduler, _Sexpr, _Receiver>* __state_;
177 template <class _Scheduler, class _Sexpr, class _Receiver>
181 using __receiver2_t = __receiver2<_Scheduler, _Sexpr, _Receiver>;
236 []<class _Sender, class _Receiver>(_Sender&& __sndr, _Receiver&) {
241 return __state<_Scheduler, _Sender, _Receiver>{__sched};
245 []<class _State, class _Receiver, class _Tag, class... _Args>(
246 __ignore, _State& __state, _Receiver& __rcvr, _Tag __tag,
[all …]
H A D__into_variant.hpp83 []<class _Self, class _Receiver>(_Self&&, _Receiver&) noexcept {
85 value_types_of_t<__child_of<_Self>, env_of_t<_Receiver>>;
90 []<class _State, class _Receiver, class _Tag, class... _Args>(
91 __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__when_all.hpp150 template <class _Tag, class _Receiver>
151 auto __complete_fn(_Tag, _Receiver& __rcvr) noexcept in __complete_fn()
158 template <class _Receiver, class _ValuesTuple>
206 template <class _Receiver>
207 void __arrive(_Receiver& __rcvr) noexcept in __arrive()
215 template <class _Receiver>
216 void __complete(_Receiver& __rcvr) noexcept in __complete()
324 -> __env_t<env_of_t<const _Receiver&>> {
329 []<class _Self, class _Receiver>(_Self&& __self, _Receiver& __rcvr)
338 _State& __state, _Receiver& __rcvr,
[all …]
H A D__shared.hpp66 template <class _Receiver>
67 auto __make_notify_visitor(_Receiver& __rcvr) noexcept in __make_notify_visitor()
72 __tag(static_cast<_Receiver&&>(__rcvr), in __make_notify_visitor()
95 template <class _CvrefSender, class _Receiver>
98 __enable_receiver_from_this<_CvrefSender, _Receiver>
485 []<class _CvrefSender, class _Receiver>(
487 _Receiver&) noexcept -> __local_state<_CvrefSender, _Receiver> {
489 return __local_state<_CvrefSender, _Receiver>{
501 []<class _Sender, class _Receiver>(
502 __local_state<_Sender, _Receiver>& __self,
[all …]
H A D__read_env.hpp98 []<class _Self, class _Receiver>(const _Self&, _Receiver&) noexcept {
100 using __result = __call_result_t<__query, env_of_t<_Receiver>>;
105 []<class _State, class _Receiver>(_State& __state,
106 _Receiver& __rcvr) noexcept -> void {
113 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
119 __nothrow_callable<__query, env_of_t<_Receiver>>;
127 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
H A D__bulk.hpp132 []<class _Tag, class _State, class _Receiver, class... _Args>(
133 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
144 _Tag()(static_cast<_Receiver&&>(__rcvr),
155 _Tag()(static_cast<_Receiver&&>(__rcvr),
160 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
167 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__debug.hpp241 using _Receiver = typedef
243 using _Operation = connect_result_t<_Sender, _Receiver>;
248 connect(static_cast<_Sender&&>(__sndr), _Receiver{});
266 using _Receiver = typedef
268 using _Operation = connect_result_t<_Sender, _Receiver>;
273 connect(static_cast<_Sender&&>(__sndr), _Receiver{});
H A D__then.hpp90 []<class _Tag, class _State, class _Receiver, class... _Args>(
91 __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_error.hpp92 []<class _Tag, class _State, class _Receiver, class... _Args>(
93 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
97 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
103 _Tag()(static_cast<_Receiver&&>(__rcvr),
H A D__upon_stopped.hpp93 []<class _Tag, class _State, class _Receiver, class... _Args>(
94 __ignore, _State& __state, _Receiver& __rcvr, _Tag,
98 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
104 _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__just.hpp47 []<class _State, class _Receiver>(_State& __state,
48 _Receiver& __rcvr) noexcept -> void {
51 __tag_t()(static_cast<_Receiver&&>(__rcvr),
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp83 template <class _Receiver, class _Sender>
101 _Receiver __rcvr_;
260 template <class _Receiver>
268 template <class _Receiver, class _Item>
292 stdexec::receiver<_Receiver> && //
334 _Receiver, item_types_of_t<_Sender, stdexec::env_of_t<_Receiver>>> && //
336 stdexec::receiver_of<_Receiver,
359 sequence_receiver_of<_Receiver,
418 __tfx_sndr<_Sender, _Receiver>, _Receiver> ||
506 template <class _Receiver>
[all …]
H A Denv.hpp86 using _Receiver = stdexec::__t<_ReceiverId>; typedef
94 _Receiver __rcvr_;
100 if constexpr (__callable<_Tag, env_of_t<_Receiver>>) in start()
120 template <class _Tag, class _Default, class _Receiver>
121 using __operation_t = __t<__operation<_Tag, __id<_Default>, __id<_Receiver>>>;
143 template <__decays_to<__sender> _Self, class _Receiver>
144 requires receiver_of<_Receiver, __completions_t<env_of_t<_Receiver>>>
145 static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
146 noexcept(std::is_nothrow_move_constructible_v<_Receiver>) in connect()
147 -> __operation_t<_Tag, __default_t<env_of_t<_Receiver>>, _Receiver> in connect()
[all …]
H A Dasync_scope.hpp75 using _Receiver = stdexec::__t<_ReceiverId>; typedef
82 _Receiver __rcvr) : in __t()
123 template <class _Self, class _Receiver>
164 _Receiver __rcvr_;
289 template <class _Receiver>
293 template <class _Receiver>
301 -> __nest_operation_t<_Receiver> in connect()
423 _Receiver __rcvr_;
728 template <class _Receiver>
760 _Receiver __rcvr) -> __future_op_t<_Receiver> in connect()
[all …]
H A Dat_coroutine_exit.hpp42 template <class _Receiver>
49 _Receiver __receiver_;
52 requires __callable<set_value_t, _Receiver, _Args...>
55 stdexec::set_value(static_cast<_Receiver&&>(__receiver_), in set_value()
60 requires __callable<set_error_t, _Receiver, _Error>
72 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env()
97 template <receiver _Receiver>
98 requires sender_to<_Sender, __receiver<_Receiver>>
99 auto connect(_Receiver __rcvr) && noexcept in connect()
100 -> connect_result_t<_Sender, __receiver<_Receiver>> in connect()
[all …]
H A Dany_sender_of.hpp988 template <class _Receiver>
992 _Receiver __rcvr_;
1006 using _Receiver = stdexec::__t<_ReceiverId>; typedef
1011 __operation_base<_Receiver>* __op_;
1063 using _Receiver = stdexec::__t<_ReceiverId>; typedef
1065 class __t : public __operation_base<_Receiver>
1072 __operation_base<_Receiver>{static_cast<_Receiver&&>(__receiver)}, in __t()
1095 using _Receiver = stdexec::__t<_ReceiverId>; typedef
1117 _Receiver __rec_;
1402 _Receiver>
[all …]

12