ADD: added usage of a async callback for testing

include/DirectCommunicationClient.hpp

@@ -27,6 +27,7 @@ namespace DirectCommunication
 
             void sendMessage(std::string msg);
             std::string getLatestMessage();
+            void disconnect();
 
             void registerMessageCallback(std::function<void(std::string)> MessageHandle);
 

src/DirectCommunicationClient.cpp

@@ -2,11 +2,13 @@
 
 
 #include "zmq.hpp"
+#include <functional>
 #include <memory>
 #include <string>
 #include <sys/types.h>
 #include <thread>
 #include <loguru.hpp>
+#include <future>
 
 
 namespace DirectCommunication 
@@ -34,12 +36,24 @@ namespace DirectCommunication
     DirectCommunicationClient::~DirectCommunicationClient()
     {
         sendMessage("CLOSE");
-        isConnected = false;
 
         stopWorker_ = true;
         Worker_.join();
 
         socket_.close();
+        isConnected = false;
+    }
+
+    void DirectCommunicationClient::disconnect()
+    {
+        sendMessage("CLOSE");
+
+        stopWorker_ = true;
+        Worker_.join();
+
+        socket_.close();
+        isConnected = false;
+        
     }
 
      void DirectCommunicationClient::registerMessageCallback(std::function<void(std::string)> MessageHandle)
@@ -90,7 +104,8 @@ namespace DirectCommunication
                 {
                     if (MessageHandle_ != nullptr) 
                     {   
-                        MessageHandle_(msg.to_string());
+                        auto i = std::async(std::launch::async, MessageHandle_, msg.to_string());
+                        // MessageHandle_(msg.to_string());
                     }
                     else 
                     {