From c28cdf2fbf1565709b359c9cca6c5e29d9592dce Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 02 四月 2021 15:51:20 +0800
Subject: [PATCH] typedef Topic.
---
src/pubsub.h | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/pubsub.h b/src/pubsub.h
index ac5a9d2..3c3d4ad 100644
--- a/src/pubsub.h
+++ b/src/pubsub.h
@@ -33,8 +33,8 @@
shm_(shm) {}
SocketPublish() :
SocketPublish(BHomeShm()) {}
- bool Publish(const std::string &topic, const void *data, const size_t size, const int timeout_ms);
- bool Publish(const std::string &topic, const std::string &data, const int timeout_ms)
+ bool Publish(const Topic &topic, const void *data, const size_t size, const int timeout_ms);
+ bool Publish(const Topic &topic, const std::string &data, const int timeout_ms)
{
return Publish(topic, data.data(), data.size(), timeout_ms);
}
@@ -52,11 +52,11 @@
SocketSubscribe(BHomeShm()) {}
~SocketSubscribe() { Stop(); }
- typedef std::function<void(const std::string &topic, const std::string &data)> TopicDataCB;
+ typedef std::function<void(const Topic &topic, const std::string &data)> TopicDataCB;
bool StartRecv(const TopicDataCB &tdcb, int nworker = 2);
bool Stop() { return Socket::Stop(); }
- bool Subscribe(const std::vector<std::string> &topics, const int timeout_ms);
- bool RecvSub(std::string &topic, std::string &data, const int timeout_ms);
+ bool Subscribe(const std::vector<Topic> &topics, const int timeout_ms);
+ bool RecvSub(Topic &topic, std::string &data, const int timeout_ms);
};
#endif // end of include guard: PUBSUB_4KGRA997
--
Gitblit v1.8.0