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.hpp38 template <__same_as<set_value_t> _Self, class _Receiver, class... _As>
40 friend auto tag_invoke(_Self, _Receiver&& __rcvr, _As&&... __as) noexcept in tag_invoke()
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()
55 template <class _Receiver, class... _As>
56 requires tag_invocable<set_value_t, _Receiver, _As...>
58 void operator()(_Receiver&& __rcvr, _As&&... __as) const noexcept in operator ()()
60 static_assert(nothrow_tag_invocable<set_value_t, _Receiver, _As...>); in operator ()()
[all …]
H A D__senders.hpp192 template <class _Sender, class _Receiver>
194 transform_sender_result_t<__late_domain_of_t<_Sender, env_of_t<_Receiver>>,
195 _Sender, env_of_t<_Receiver>>;
197 template <class _Sender, class _Receiver>
199 decltype(__declval<_Sender>().connect(__declval<_Receiver>()));
201 template <class _Sender, class _Receiver>
204 ::connect(__declval<_Sender>(), __declval<_Receiver>()));
206 template <class _Sender, class _Receiver>
207 concept __with_member = __mvalid<__member_result_t, _Sender, _Receiver>;
209 template <class _Sender, class _Receiver>
[all …]
H A D__basic_sender.hpp78 template <class _Sexpr, class _Receiver>
81 template <class _Sexpr, class _Receiver>
84 template <class _Tag, class _Sexpr, class _Receiver>
86 __decay_t<__result_of<__sexpr_impl<_Tag>::get_state, _Sexpr, _Receiver&>>;
88 template <class _Self, class _Tag, class _Index, class _Sexpr, class _Receiver>
91 __state_type_t<__meval<__msecond, _Self, _Tag>, _Sexpr, _Receiver>&,
92 _Receiver&>;
94 template <class _Sexpr, class _Receiver>
97 __connect_fn<_Sexpr, _Receiver>> &&
98 __mvalid<__state_type_t, tag_of_t<_Sexpr>, _Sexpr, _Receiver>;
[all …]
H A D__connect_awaitable.hpp114 using _Receiver = stdexec::__t<_ReceiverId>; typedef
121 __t(auto&&, _Receiver&& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
123 explicit __t(auto&, _Receiver& __rcvr) noexcept : __rcvr_(__rcvr) {} in __t()
128 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
159 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env()
164 _Receiver& __rcvr_;
168 template <receiver _Receiver>
169 using __promise_t = __t<__promise<__id<_Receiver>>>;
171 template <receiver _Receiver>
172 using __operation_t = __t<__operation<__id<_Receiver>>>;
[all …]
H A D__submit.hpp52 using _Receiver = stdexec::__t<__mapply<__q<__msecond>, _Operation>>; typedef
59 if constexpr (__callable<get_allocator_t, env_of_t<_Receiver>>) in __delete_op()
80 stdexec::set_value(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_value()
88 stdexec::set_error(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_error()
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>
[all …]
H A D__let.hpp107 template <class _Receiver, class _Scheduler>
111 _Receiver __rcvr_;
117 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_), in set_value()
124 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in set_error()
130 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
141 template <class _Receiver, class _Scheduler>
142 __receiver_with_sched(_Receiver, _Scheduler)
143 -> __receiver_with_sched<_Receiver, _Scheduler>;
206 template <class _Receiver, class _Scheduler>
208 __if_c<__is_scheduler_affine<schedule_result_t<_Scheduler>>, _Receiver,
[all …]
H A D__schedule_from.hpp116 template <class _Scheduler, class _Sexpr, class _Receiver>
146 template <class _Scheduler, class _Sexpr, class _Receiver>
160 stdexec::set_error(static_cast<_Receiver&&>(__state_->__receiver()), in set_error()
166 stdexec::set_stopped(static_cast<_Receiver&&>(__state_->__receiver())); in set_stopped()
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>
179 __enable_receiver_from_this<_Sexpr, _Receiver,
180 __state<_Scheduler, _Sexpr, _Receiver>>,
183 using __variant_t = __variant_for<__child_of<_Sexpr>, env_of_t<_Receiver>>;
[all …]
H A D__run_loop.hpp60 using _Receiver = stdexec::__t<_ReceiverId>; typedef
68 _Receiver __rcvr_;
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)}
123 template <class _Receiver>
125 stdexec::__t<__operation<stdexec::__id<_Receiver>>>;
127 template <class _Receiver>
[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__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__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,
99 __local_state<_CvrefSender, _Receiver>>
102 using __stok_t = stop_token_of_t<env_of_t<_Receiver>>;
144 stdexec::set_stopped(static_cast<_Receiver&&>(this->__receiver())); in operator ()()
487 []<class _CvrefSender, class _Receiver>(
489 _Receiver&) noexcept -> __local_state<_CvrefSender, _Receiver> {
[all …]
H A D__when_all.hpp150 template <class _Tag, class _Receiver>
151 auto __complete_fn(_Tag, _Receiver& __rcvr) noexcept in __complete_fn()
154 _Tag()(static_cast<_Receiver&&>(__rcvr), static_cast<_Ts&&>(__ts)...); in __complete_fn()
158 template <class _Receiver, class _ValuesTuple>
159 void __set_values(_Receiver& __rcvr, _ValuesTuple& __values) noexcept in __set_values()
206 template <class _Receiver>
207 void __arrive(_Receiver& __rcvr) noexcept in __arrive()
215 template <class _Receiver>
216 void __complete(_Receiver& __rcvr) noexcept in __complete()
239 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __complete()
[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.hpp136 []<class _Tag, class _State, class _Receiver, class... _Args>(
137 __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__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_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__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__inline_scheduler.hpp82 []<class _Receiver>(__ignore, _Receiver& __rcvr) noexcept -> void {
83 stdexec::set_value(static_cast<_Receiver&&>(__rcvr));
H A D__p2300.hpp130 template <class _Receiver>
131 concept receiver /*STDEXEC_STD_DEPRECATED*/ = stdexec::receiver<_Receiver>;
133 template <class _Receiver, class _Completions>
135 stdexec::receiver_of<_Receiver, _Completions>;
164 template <class _Sender, class _Receiver>
166 stdexec::sender_to<_Sender, _Receiver>;
215 template <class _Sender, class _Receiver>
217 stdexec::connect_result_t<_Sender, _Receiver>;
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp65 template <receiver _Receiver, sender _Item>
66 requires tag_invocable<set_next_t, _Receiver&, _Item>
67 auto operator()(_Receiver& __rcvr, _Item&& __item) const in operator ()()
68 noexcept(nothrow_tag_invocable<set_next_t, _Receiver&, _Item>) in operator ()()
69 -> tag_invoke_result_t<set_next_t, _Receiver&, _Item> in operator ()()
72 next_sender<tag_invoke_result_t<set_next_t, _Receiver&, _Item>>, in operator ()()
83 template <class _Receiver, class _Sender>
85 stdexec::__declval<stdexec::__decay_t<_Receiver>&>(),
98 using _Receiver = stdexec::__t<_ReceiverId>; typedef
99 using _Token = stop_token_of_t<env_of_t<_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.hpp76 using _Receiver = stdexec::__t<_ReceiverId>; typedef
83 _Receiver __rcvr) : in __t()
86 static_cast<_Receiver&&>(__rcvr)))
110 connect_result_t<_Constrained, _Receiver> __op_;
124 template <class _Self, class _Receiver>
127 stdexec::__id<_Receiver>>>;
129 template <__decays_to<__t> _Self, receiver _Receiver>
130 requires sender_to<__copy_cvref_t<_Self, _Constrained>, _Receiver>
131 [[nodiscard]] static auto connect(_Self&& __self, _Receiver __rcvr) // in connect()
132 -> __when_empty_op_t<_Self, _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>
63 stdexec::set_error(static_cast<_Receiver&&>(__receiver_), in set_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()
[all …]
H A Dany_sender_of.hpp987 template <class _Receiver>
991 _Receiver __rcvr_;
994 stdexec::env_of_t<_Receiver>>::template callback_type<__on_stop_t>;
1005 using _Receiver = stdexec::__t<_ReceiverId>; typedef
1010 __operation_base<_Receiver>* __op_;
1013 requires __callable<set_next_t, _Receiver&, _Item>
1016 -> __call_result_t<set_next_t, _Receiver&, _Item> in STDEXEC_MEMFN_DECL()
1023 requires __callable<set_value_t, _Receiver, _Args...>
1027 stdexec::set_value(static_cast<_Receiver&&>(__op_->__rcvr_), in set_value()
1032 requires __callable<set_error_t, _Receiver, _Error>
[all …]

12