-- mqtt协议解析剩余长度判断不一致，导致解析异常connection 断连 (#81)

Co-authored-by: levili <wei.li02@narwal.com>
shamblett · Jan 21, 2024 · 128ae14 · 128ae14
1 parent d065797
commit 128ae14
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/src/utility/mqtt_byte_buffer.dart b/lib/src/utility/mqtt_byte_buffer.dart
@@ -84,10 +84,11 @@ class MqttByteBuffer {
     var position = _position;
     var header = MqttHeader.fromByteBuffer(this);
     // Restore the position
+    final avibytes = availableBytes; // should same in MqttMessage.createFrom
     _position = position;
-    if (availableBytes < header.messageSize) {
+    if (avibytes < header.messageSize) {
       MqttLogger.log(
-          'MqttByteBuffer:isMessageAvailable - Available bytes($availableBytes) is less than the message size'
+          'MqttByteBuffer:isMessageAvailable - Available bytes($avibytes) is less than the message size'
           ' ${header.messageSize}');
 
       return false;