Smikkelbakje/J2S1-Kobuki
1
0
Fork 0
mirror of https://gitlab.fdmci.hva.nl/technische-informatica-sm3/ti-projectten/rooziinuubii79.git synced 2025-08-03 20:04:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

making message print only once

Browse Source
This commit is contained in:
ishak jmilou.ishak
2024-12-18 11:56:43 +01:00
parent 50b6b83299
commit e5881f1b37
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/C++/Driver/src/main.cpp
View File

@@ -36,9 +36,10 @@ int main()
std::thread sendMqtt([&]() { sendKobukiData(robot.parser.data); }); std::thread sendMqtt([&]() { sendKobukiData(robot.parser.data); });
while(true){ while(true){
parseMQTT(readMQTT()); std::string message = readMQTT();
std::this_thread::sleep_for(std::chrono::milliseconds(static_cast<int>(10))); if (!message.empty()){
parseMQTT(message);
}
} }
@@ -49,10 +50,13 @@ int main()
std::string readMQTT() std::string readMQTT()
{ {
message = client.getLastMessage(); static std::string lastMessage;
if (!message.empty())
std::string message = client.getLastMessage();
if (!message.empty() && message != lastMessage)
{ {
std::cout << "MQTT Message: " << message << std::endl; std::cout << "MQTT Message: " << message << std::endl;
lastMessage = message;
} }
// Add a small delay to avoid busy-waiting // Add a small delay to avoid busy-waiting