Lines Matching refs:stdexec
410 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto sendRecvMsg(
469 template <class RequestInterface, stdexec::receiver R>
500 friend void tag_invoke(stdexec::start_t, SendRecvMsgOperation& op) noexcept in tag_invoke()
502 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
507 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
517 return stdexec::set_value(std::move(op.receiver), rc, in tag_invoke()
537 return stdexec::set_stopped(std::move(receiver)); in onStop()
558 return stdexec::set_value(std::move(receiver), static_cast<int>(rc), in onComplete()
592 std::optional<typename stdexec::stop_token_of_t<
593 stdexec::env_of_t<R>>::template callback_type<std::function<void()>>>
615 friend auto tag_invoke(stdexec::get_completion_signatures_t,
617 -> stdexec::completion_signatures<
618 stdexec::set_value_t(int, const pldm_msg*, size_t),
619 stdexec::set_stopped_t()>;
622 template <stdexec::receiver R>
623 friend auto tag_invoke(stdexec::connect_t, SendRecvMsgSender&& self, R r) in tag_invoke()
652 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto
657 stdexec::then([](int rc, const pldm_msg* resp, size_t respLen) { in sendRecvMsg()