Merge branch 'main' into concurrent_features

Author: eigen-value

library.json

@@ -11,7 +11,7 @@
     "url": "https://github.com/eigen-value",
     "maintainer": true
   },
-  "version": "0.1.1",
+  "version": "0.1.2",
   "license": "MIT",
   "frameworks": "arduino",
   "platforms": "*",

library.properties

@@ -1,5 +1,5 @@
 name=Arduino_RPClite
-version=0.1.1
+version=0.1.2
 author=Lucio Rossi (eigen-value)
 maintainer=Lucio Rossi (eigen-value)
 sentence=A MessagePack RPC library for Arduino

src/SerialTransport.h

@@ -21,7 +21,7 @@ class SerialTransport: public ITransport {
         size_t write(const uint8_t* data, size_t size) override {
             _stream->write(data, size);
             return size;
-        }   
+        }
 
         size_t read(uint8_t* buffer, size_t size) override {
             _stream->setTimeout(0);

src/decoder.h

@@ -215,8 +215,17 @@ class RpcDecoder {
 
     inline bool buffer_empty() const { return _bytes_stored == 0;}
 
+    // This is a blocking send, under the assumption _transport.write will always succeed eventually
     inline size_t send(const uint8_t* data, const size_t size) {
-        return _transport.write(data, size);
+
+        size_t offset = 0;
+
+        while (offset < size) {
+            size_t bytes_written = _transport.write(data + offset, size - offset);
+            offset += bytes_written;
+        }
+
+        return offset;
     }
 
     size_t pop_packet(uint8_t* buffer, size_t buffer_size) {