From 3c2b6739208d961cf8b86460d7f05516d044960c Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期三, 31 三月 2021 19:13:42 +0800 Subject: [PATCH] add async recv suport; sync by waiting for async. --- src/msg.h | 2 ++ 1 files changed, 2 insertions(+), 0 deletions(-) diff --git a/src/msg.h b/src/msg.h index 2154eba..ea1e636 100644 --- a/src/msg.h +++ b/src/msg.h @@ -59,7 +59,9 @@ int num_ = 1; }; +BHMsg MakeQueryTopic(const std::string &topic); BHMsg MakeRequest(const MQId &src_id, const void *data, const size_t size); +BHMsg MakeRequest(const MQId &src_id, const std::string &topic, const void *data, const size_t size); BHMsg MakeReply(const void *data, const size_t size); BHMsg MakeSub(const MQId &client, const std::vector<std::string> &topics); BHMsg MakeUnsub(const MQId &client, const std::vector<std::string> &topics); -- Gitblit v1.8.0