Home
last modified time | relevance | path

Searched refs:env_of_t (Results 1 – 25 of 28) sorted by relevance

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp99 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 Denv.hpp100 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 Dtask.hpp195 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 Dat_coroutine_exit.hpp72 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 Dany_sender_of.hpp102 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 Dasync_scope.hpp231 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.hpp38 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.hpp193 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.hpp222 __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.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()
129 if constexpr (__callable<get_allocator_t, env_of_t<_Receiver>>) in operator ()()
H A D__execution_fwd.hpp77 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.hpp78 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.hpp169 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.hpp110 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.hpp233 __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.hpp47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
H A D__ensure_started.hpp47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
H A D__into_variant.hpp85 value_types_of_t<__child_of<_Self>, env_of_t<_Receiver>>;
H A D__p2300.hpp116 using env_of_t STDEXEC_STD_DEPRECATED = stdexec::env_of_t<_EnvProvider>; typedef
H A D__connect_awaitable.hpp155 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env()
H A D__receiver_adaptor.hpp181 auto get_env() const noexcept -> env_of_t<__base_t<const _Self&>> in get_env()
H A D__when_all.hpp324 -> __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.hpp199 __completion_signatures_of_t<_Sender, env_of_t<_Receiver>>>;
H A D__transform_sender.hpp303 __call_result_t<get_completion_scheduler_t<_Tag>, env_of_t<_Sender>>,
H A D__shared.hpp101 using __stok_t = stop_token_of_t<env_of_t<_Receiver>>;

12