From 82ea7853e8256b4a6b584cce49f6f4afbf15dd42 Mon Sep 17 00:00:00 2001
From: Johannes Schriewer <hallo@dunkelstern.de>
Date: Mon, 30 Jul 2018 22:03:33 +0200
Subject: [PATCH] BUGFIX: Handling incomplete buffers was totally wrong

---
 src/mqtt.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/mqtt.c b/src/mqtt.c
index fd579e7..a585224 100644
--- a/src/mqtt.c
+++ b/src/mqtt.c
@@ -111,8 +111,8 @@ static void _reader(MQTTHandle *handle) {
                     // Not complete recv buffer was consumed, so we have more than one packet in there
                     size_t remaining = max_receive_buffer_size - buffer->position;
                     memmove(read_buffer, read_buffer + buffer->position, remaining);
-                    offset -= remaining;
-                    num_bytes -= remaining;
+                    offset -= buffer->position;
+                    num_bytes -= buffer->position;
                     free(buffer);
                 } else {
                     // buffer consumed completely, read another chunk