Update DelegateMQ source

Author: endurodave

DelegateMQ/delegate/Delegate.h

@@ -7,7 +7,7 @@
 
 /// @file
 /// @brief Delegate series of classes are used to invoke a function synchronously. 
-/// @details Delgates support binding to free functions, class instance functions, class 
+/// @details Delegates support binding to free functions, class instance functions, class 
 /// static function, and std::function targets. Lambda functions can be bound to a delegate 
 /// when assigned to a `std::function`. The classes are not thread-safe.
 /// 

DelegateMQ/delegate/DelegateRemote.h

@@ -353,6 +353,7 @@ class DelegateFreeRemote<RetType(Args...)> : public DelegateFree<RetType(Args...
 
         if (!is.good()) {
             RaiseError(m_id, DelegateError::ERR_STREAM_NOT_GOOD);
+            return false;
         }
 
         // Invoke the delegate function synchronously
@@ -521,6 +522,7 @@ class DelegateFreeRemote<RetType(Args...)> : public DelegateFree<RetType(Args...
     /// @param[in] auxCode Optional auxiliary code.
     /// @throws std::runtime_error If no error handler is registered.
     void RaiseError(DelegateRemoteId id, DelegateError error, DelegateErrorAux auxCode = 0) {
+        m_error = error;
         if (m_errorHandler) {
             m_errorHandler(id, error, auxCode);
         } else {
@@ -862,6 +864,7 @@ class DelegateMemberRemote<TClass, RetType(Args...)> : public DelegateMember<TCl
 
         if (!is.good()) {
             RaiseError(m_id, DelegateError::ERR_STREAM_NOT_GOOD);
+            return false;
         }
 
         // Invoke the delegate function synchronously
@@ -1030,6 +1033,7 @@ class DelegateMemberRemote<TClass, RetType(Args...)> : public DelegateMember<TCl
     /// @param[in] auxCode Optional auxiliary code.
     /// @throws std::runtime_error If no error handler is registered.
     void RaiseError(DelegateRemoteId id, DelegateError error, DelegateErrorAux auxCode = 0) {
+        m_error = error;
         if (m_errorHandler) {
             m_errorHandler(id, error, auxCode);
         } else {
@@ -1073,8 +1077,7 @@ struct DelegateFunctionRemote; // Not defined
 
 /// @brief `DelegateFunctionRemote<>` class asynchronously invokes a `std::function` target function.
 /// @details Caution when binding to a `std::function` using this class. `std::function` cannot be 
-/// compared for equality directly in a meaningful way using `operator==`. Therefore, the delegate
-/// library used 
+/// compared for equality directly in a meaningful way using `operator==`.  
 /// 
 /// See `DelegateFunction<>` base class for important usage limitations.
 /// 
@@ -1312,6 +1315,7 @@ class DelegateFunctionRemote<RetType(Args...)> : public DelegateFunction<RetType
 
         if (!is.good()) {
             RaiseError(m_id, DelegateError::ERR_STREAM_NOT_GOOD);
+            return false;
         }
 
         // Invoke the delegate function synchronously
@@ -1480,6 +1484,7 @@ class DelegateFunctionRemote<RetType(Args...)> : public DelegateFunction<RetType
     /// @param[in] auxCode Optional auxiliary code.
     /// @throws std::runtime_error If no error handler is registered.
     void RaiseError(DelegateRemoteId id, DelegateError error, DelegateErrorAux auxCode = 0) {
+        m_error = error;
         if (m_errorHandler) {
             m_errorHandler(id, error, auxCode);
         } else {

DelegateMQ/delegate/UnicastDelegateSafe.h

@@ -3,7 +3,7 @@
 
 /// @file
 /// @brief Delegate container for storing an invoking a single delegate instance. 
-/// Class is not thread-safe.
+/// Class is thread-safe.
 
 #include "UnicastDelegate.h"
 #include <mutex>

DelegateMQ/predef/serialize/msgpack/Serializer.h

@@ -54,6 +54,7 @@ class Serializer<RetType(Args...)> : public dmq::ISerializer<RetType(Args...)>
     // Write arguments to a stream
     virtual std::ostream& Write(std::ostream& os, Args... args) override {
         try {
+            os.seekp(0, std::ios::beg);
             msgpack::sbuffer buffer;
             make_serialized(buffer, args...);
             os.write(buffer.data(), buffer.size());

DelegateMQ/predef/serialize/rapidjson/Serializer.h

@@ -49,6 +49,7 @@ class Serializer<RetType(Args...)> : public dmq::ISerializer<RetType(Args...)>
     // Write arguments to a stream
     virtual std::ostream& Write(std::ostream& os, Args... args) override {
         try {
+            os.seekp(0, std::ios::beg);
             rapidjson::StringBuffer sb;
             rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(sb);
 

DelegateMQ/predef/serialize/serialize/Serializer.h

@@ -45,6 +45,7 @@ class Serializer<RetType(Args...)> : public dmq::ISerializer<RetType(Args...)>
     // Write arguments to a stream
     virtual std::ostream& Write(std::ostream& os, Args... args) override {
         try {
+            os.seekp(0, std::ios::beg);
             serialize ser;
             make_serialized(ser, os, args...);
         }

DelegateMQ/predef/transport/mqtt/MqttTransport.h

@@ -145,7 +145,7 @@ class MqttTransport : public ITransport
         ss << seqNum << "] ";
 
         // Insert delegate arguments from the stream (os)
-        ss << os.rdbuf();
+        ss << os.str();
 
         size_t payloadLen = ss.str().length();
 

DelegateMQ/predef/transport/win32-pipe/Win32PipeTransport.h

@@ -92,7 +92,7 @@ class Win32PipeTransport : public ITransport
         ss.write(reinterpret_cast<const char*>(&seqNum), sizeof(seqNum));
 
         // Insert delegate arguments from the stream (os)
-        ss << os.rdbuf();
+        ss << os.str();
 
         size_t length = ss.str().length();
         char* sendBuf = (char*)malloc(length);

DelegateMQ/predef/transport/win32-udp/Win32UdpTransport.h

@@ -100,7 +100,7 @@ class Win32UdpTransport : public ITransport
         ss.write(reinterpret_cast<const char*>(&seqNum), sizeof(seqNum));
 
         // Insert delegate arguments from the stream (os)
-        ss << os.rdbuf();
+        ss << os.str();
 
         size_t length = ss.str().length();
 

DelegateMQ/predef/transport/zeromq/ZeroMqTransport.h

@@ -129,7 +129,7 @@ class ZeroMqTransport : public ITransport
         ss.write(reinterpret_cast<const char*>(&seqNum), sizeof(seqNum));
 
         // Insert delegate arguments from the stream (os)
-        ss << os.rdbuf();
+        ss << os.str();
 
         size_t length = ss.str().length();