Lines Matching refs:stdexec
417 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto sendRecvMsg(
476 template <class RequestInterface, stdexec::receiver R>
507 friend void tag_invoke(stdexec::start_t, SendRecvMsgOperation& op) noexcept in tag_invoke()
509 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
514 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
524 return stdexec::set_value(std::move(op.receiver), rc, in tag_invoke()
544 return stdexec::set_stopped(std::move(receiver)); in onStop()
565 return stdexec::set_value(std::move(receiver), static_cast<int>(rc), in onComplete()
599 std::optional<typename stdexec::stop_token_of_t<
600 stdexec::env_of_t<R>>::template callback_type<std::function<void()>>>
622 friend auto tag_invoke(stdexec::get_completion_signatures_t,
624 -> stdexec::completion_signatures<
625 stdexec::set_value_t(int, const pldm_msg*, size_t),
626 stdexec::set_stopped_t()>;
629 template <stdexec::receiver R>
630 friend auto tag_invoke(stdexec::connect_t, SendRecvMsgSender&& self, R r) in tag_invoke()
659 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto
664 stdexec::then([](int rc, const pldm_msg* resp, size_t respLen) { in sendRecvMsg()