Persson-dev/Simple-Protocol-Lib
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

Add TCP support #12

Merged
Persson-dev merged 12 commits from tcp into main 2025-03-03 10:04:42 +00:00
Conversation 0 Commits 12 Files Changed 16 +3 -13
1 changed files with 3 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit c46c5bed6f - Show all commits

16
include/sp/protocol/message/MessageDispatcherImpl.inl
View File

@@ -2,18 +2,14 @@
template <typename MessageIdType, typename MessageBase, typename MessageHandler>
void MessageDispatcher<MessageIdType, MessageBase, MessageHandler>::RegisterHandler(MessageIdType a_MessageType, MessageHandler* a_Handler) {
auto found = std::find_if(m_Handlers[a_MessageType].begin(), m_Handlers[a_MessageType].end(), [&a_Handler](const MessageHandler* handler){
return a_Handler == handler;
});
auto found = std::find(m_Handlers[a_MessageType].begin(), m_Handlers[a_MessageType].end(), a_Handler);
if (found == m_Handlers[a_MessageType].end())
m_Handlers[a_MessageType].push_back(a_Handler);
}
template <typename MessageIdType, typename MessageBase, typename MessageHandler>
void MessageDispatcher<MessageIdType, MessageBase, MessageHandler>::UnregisterHandler(MessageIdType a_MessageType, MessageHandler* a_Handler) {
auto found = std::find_if(m_Handlers[a_MessageType].begin(), m_Handlers[a_MessageType].end(), [&a_Handler](const MessageHandler* handler){
return a_Handler == handler;
});
auto found = std::find(m_Handlers[a_MessageType].begin(), m_Handlers[a_MessageType].end(), a_Handler);
if (found != m_Handlers[a_MessageType].end())
m_Handlers[a_MessageType].erase(found);
}
@@ -26,13 +22,7 @@ void MessageDispatcher<MessageIdType, MessageBase, MessageHandler>::UnregisterHa
MessageIdType type = pair.first;
auto it = std::find_if(pair.second.begin(), pair.second.end(), [&a_Handler](MessageHandler* handler){
return handler == a_Handler;
});
if (it != pair.second.end())
pair.second.erase(it);
pair.second.erase(std::remove(pair.second.begin(), pair.second.end(), a_Handler), pair.second.end());
}
}