/openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
H A D | sequence_senders.hpp | 99 using _Token = stop_token_of_t<env_of_t<_Receiver>>; 103 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() 335 ((sequence_sender_in<_Sender, stdexec::env_of_t<_Receiver>> && 339 (!sequence_sender_in<_Sender, stdexec::env_of_t<_Receiver>> && 357 sender_in<_Sender, env_of_t<_Receiver>> && // 358 !sequence_sender_in<_Sender, env_of_t<_Receiver>> && // 367 sequence_sender_in<_Sender, env_of_t<_Receiver>> && // 374 using __tfx_sndr = __tfx_sender<_Sender, env_of_t<_Receiver>>; 382 env_of_t<_Receiver&>>; in __select_impl() 419 __is_debug_env<env_of_t<_Receiver>> [all …]
|
H A D | env.hpp | 100 if constexpr (__callable<_Tag, env_of_t<_Receiver>>) in start() 144 requires receiver_of<_Receiver, __completions_t<env_of_t<_Receiver>>> 147 -> __operation_t<_Tag, __default_t<env_of_t<_Receiver>>, _Receiver> in connect()
|
H A D | task.hpp | 195 using __stop_token_t = stop_token_of_t<env_of_t<_ParentPromise>>; 224 stop_token_of_t<env_of_t<_ParentPromise>>> 239 requires unstoppable_token<stop_token_of_t<env_of_t<_ParentPromise>>> 268 using __stop_token_t = stop_token_of_t<env_of_t<_ParentPromise>>; in __default_awaiter_context() 291 typename __decay_t<env_of_t<_Promise>> //
|
H A D | at_coroutine_exit.hpp | 72 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() 114 auto get_env() const noexcept -> env_of_t<_Sender> in get_env()
|
H A D | any_sender_of.hpp | 102 requires __callable<_Tag, env_of_t<const _EnvProvider&>, _As...> 114 requires __callable<_Tag, env_of_t<const _EnvProvider&>, _As...> 120 __nothrow_callable<_Tag, const env_of_t<_EnvProvider>&, in __anon1bf2f58b0202() 995 stdexec::env_of_t<_Receiver>>::template callback_type<__on_stop_t>; 1048 auto get_env() const noexcept -> __env_t<env_of_t<_Receiver>> in get_env() 1392 using __env_t = stdexec::env_of_t<__receiver_base>; 1437 auto get_env() const noexcept -> stdexec::env_of_t<__receiver_base> in get_env()
|
H A D | async_scope.hpp | 231 auto get_env() const noexcept -> __env_t<env_of_t<_Receiver>> in get_env() 368 env_of_t<_Receiver>>::template callback_type<__forward_stopped>;
|
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
H A D | __read_env.hpp | 38 using __result_t = __call_result_t<_Tag, env_of_t<stdexec::__t<_ReceiverId>>>; 42 __nothrow_callable<_Tag, env_of_t<stdexec::__t<_ReceiverId>>>; 100 using __result = __call_result_t<__query, env_of_t<_Receiver>>; 119 __nothrow_callable<__query, env_of_t<_Receiver>>;
|
H A D | __senders.hpp | 193 transform_sender_result_t<__late_domain_of_t<_Sender, env_of_t<_Receiver>>, 194 _Sender, env_of_t<_Receiver>>; 240 using _Domain = __late_domain_of_t<_Sender, env_of_t<_Receiver>>; in __select_impl() 244 env_of_t<_Receiver>>; in __select_impl() 247 static_assert(__check_signatures<_TfxSender, env_of_t<_Receiver>>()); in __select_impl() 302 __is_debug_env<env_of_t<_Receiver>> 380 && sender_in<_Sender, env_of_t<_Receiver>> //
|
H A D | __let.hpp | 222 __receiver_ref_t<_ResultSender, _Scheduler, env_of_t<_Receiver>>> && 238 __receiver_ref_t<_ResultSender, _Scheduler, env_of_t<_Receiver>>, 270 __query_result_or_t<get_completion_scheduler_t<_Set>, env_of_t<_Sender>, 388 __mcall<__result_sender_fn<_Set, _Fun, _Sched, env_of_t<_Receiver>>, 399 using __env_t = __result_env_t<_Sched, env_of_t<_Receiver>>; 413 __receiver_ref_t<_ResultSender, _Sched, env_of_t<_Receiver>>; in __get_result_receiver() 530 __gather_completions_of<_Set, _Child, env_of_t<_Receiver>, 564 __mcall<__result_sender_fn<_Set, _Fun, _Sched, env_of_t<_Receiver>>, in __bind() 573 _ResultSender, _Sched, env_of_t<_Receiver>>>) in __bind()
|
H A D | __submit.hpp | 59 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() 129 if constexpr (__callable<get_allocator_t, env_of_t<_Receiver>>) in operator ()()
|
H A D | __execution_fwd.hpp | 77 using env_of_t = __call_result_t<get_env_t, _EnvProvider>; typedef 133 __callable<get_completion_scheduler_t<_CPO>, env_of_t<const _Sender&>>; 137 __call_result_t<get_completion_scheduler_t<_CPO>, env_of_t<const _Sender&>>;
|
H A D | __stopped_as_optional.hpp | 78 requires __single_value_sender<__child_of<_Self>, env_of_t<_Receiver>> 82 __single_sender_value_t<__child_of<_Self>, env_of_t<_Receiver>>>;
|
H A D | __schedule_from.hpp | 169 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() 180 using __variant_t = __variant_for<__child_of<_Sexpr>, env_of_t<_Receiver>>; 219 env_of_t<_Sender>>>;
|
H A D | __as_awaitable.hpp | 110 auto get_env() const noexcept -> env_of_t<_Promise&> in get_env() 138 __decay_t<__value_types_of_t<_Sender, env_of_t<_Promise&>, 207 sender_in<_Sender, env_of_t<_Promise&>> && //
|
H A D | __domain.hpp | 233 __t<__completion_domain_or_none_<env_of_t<_Sender>>>; 253 if constexpr (__callable<get_domain_t, env_of_t<_Sender>>) 255 return __domain_of_t<env_of_t<_Sender>>();
|
H A D | __split.hpp | 47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
|
H A D | __ensure_started.hpp | 47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
|
H A D | __into_variant.hpp | 85 value_types_of_t<__child_of<_Self>, env_of_t<_Receiver>>;
|
H A D | __p2300.hpp | 116 using env_of_t STDEXEC_STD_DEPRECATED = stdexec::env_of_t<_EnvProvider>; typedef
|
H A D | __connect_awaitable.hpp | 155 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env()
|
H A D | __receiver_adaptor.hpp | 181 auto get_env() const noexcept -> env_of_t<__base_t<const _Self&>> in get_env()
|
H A D | __when_all.hpp | 324 -> __env_t<env_of_t<const _Receiver&>> { 330 -> __sexpr_apply_result_t<_Self, __mk_state_fn_t<env_of_t<_Receiver>>> {
|
H A D | __receivers.hpp | 199 __completion_signatures_of_t<_Sender, env_of_t<_Receiver>>>;
|
H A D | __transform_sender.hpp | 303 __call_result_t<get_completion_scheduler_t<_Tag>, env_of_t<_Sender>>,
|
H A D | __shared.hpp | 101 using __stok_t = stop_token_of_t<env_of_t<_Receiver>>;
|