 |
|
用于Topic的异步发布
#include "MsgTopic.hpp"
类 | |
| struct | Config |
| 启动异步发布时携带的配置参数 更多... | |
Public 类型 | |
| using | Callback = std::function< void()> |
| 连接状态回调 更多... | |
Public 成员函数 | |
| MsgTopicPublisherAsync () | |
| ErrCodeE | CreateMsgTopicPublisherAsync (const Config &cfg) |
| 创建异步Topic发布 更多... | |
| void | DestroyMsgTopicPublisherAsync () |
| 销毁异步Topic发布 更多... | |
| ErrCodeE | Publish (uint32_t topic, const char *data, int32_t size) |
| 发布一条Topic 更多... | |
 Public 成员函数 继承自 Emx::EuvPipeClientBase | |
| EuvPipeClientBase () | |
| virtual | ~EuvPipeClientBase () |
| Public 成员函数 继承自 Emx::EuvStmClientBase | |
| EuvStmClientBase (EuvStreamInf *stm) | |
| virtual | ~EuvStmClientBase () |
| ErrCodeE | Create (EuvLoop &loop, char *buffer, int32_t size, const char *serverIp, uint16_t serverPort, const char *localIp=nullptr, uint16_t localPort=0) |
| 创建客户端并连接服务端 更多... | |
| void | Destroy () |
| 断开链接并销毁客户端 更多... | |
| ErrCodeE | Send (std::shared_ptr< std::string > &data) |
| 向服务端发送数据 更多... | |
| void | PauseRecv () |
| 停止接收，调用后将不会收到数据 更多... | |
| ErrCodeE | ResumeRecv () |
| 开始接收数据/重新开始接收数据 更多... | |
| bool | IsReceiving () |
| 获取当前客户端是否正在监听接收 更多... | |
| std::string | GetSockName () |
| 获取本地地址 更多... | |
| std::string | GetPeerName () |
| 获取对方地址 更多... | |
Protected 成员函数 | |
| void | OnConnect () override |
| void | OnDisConnect () override |
| Protected 成员函数 继承自 Emx::EuvStmClientBase | |
| virtual void | OnRecv (const char *data, int32_t size) |
| 当有数据到来时触发此函数的调用 更多... | |
| virtual void | OnSendDone (ErrCodeE e, const char *buffer, int32_t size) |
| 当调用Send函数发送的数据成功发送至服务端，或出现错误时触发次回调 更多... | |
| using Emx::MsgTopicPublisherAsync::Callback = std::function<void()> |
|
inline |
| cfg | [in] 配置参数 |
|
inline |
| ErrCodeE Emx::MsgTopicPublisherAsync::Publish | ( | uint32_t | topic, |
| const char * | data, | ||
| int32_t | size | ||
| ) |
| topic | [in] 消息的topic |
| data | [in] topic携带的数据 |
| size | [in] topic携带数据的大小 |
|
inlineoverrideprotectedvirtual |
|
inlineoverrideprotectedvirtual |