From 2d9ae0576bf76f00c508e42d7e1256c2b909db99 Mon Sep 17 00:00:00 2001
From: Christian <6939810+chkr1011@users.noreply.github.com>
Date: Thu, 21 Apr 2022 20:49:09 +0200
Subject: [PATCH] Fix wrong value for graceful socket close handling.

---
 Source/MQTTnet/Adapter/MqttChannelAdapter.cs | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/Source/MQTTnet/Adapter/MqttChannelAdapter.cs b/Source/MQTTnet/Adapter/MqttChannelAdapter.cs
index 121c4cdc..6b9d8409 100644
--- a/Source/MQTTnet/Adapter/MqttChannelAdapter.cs
+++ b/Source/MQTTnet/Adapter/MqttChannelAdapter.cs
@@ -239,19 +239,19 @@ namespace MQTTnet.Adapter
 
                 if (cancellationToken.IsCancellationRequested)
                 {
-                    return -1;
+                    return 0;
                 }
 
                 var readCount = await _channel.ReadAsync(_singleByteBuffer, 0, 1, cancellationToken).ConfigureAwait(false);
 
                 if (cancellationToken.IsCancellationRequested)
                 {
-                    return -1;
+                    return 0;
                 }
 
                 if (readCount == 0)
                 {
-                    return -1;
+                    return 0;
                 }
 
                 _packetInspector?.FillReceiveBuffer(_singleByteBuffer);
@@ -301,8 +301,7 @@ namespace MQTTnet.Adapter
             }
 
             var bodyLength = await ReadBodyLengthAsync(buffer[1], cancellationToken).ConfigureAwait(false);
-
-            if (bodyLength == -1)
+            if (bodyLength == 0)
             {
                 return new ReadFixedHeaderResult
                 {
@@ -336,10 +335,9 @@ namespace MQTTnet.Adapter
                 return ReceivedMqttPacket.Empty;
             }
 
+            IsReadingPacket = true;
             try
             {
-                IsReadingPacket = true;
-
                 var fixedHeader = readFixedHeaderResult.FixedHeader;
                 if (fixedHeader.RemainingLength == 0)
                 {