fatal bug fix, receive content concatenated

Author: psygames

Assets/UnityWebSocket/Scripts/Runtime/Core/Settings.cs

@@ -7,6 +7,6 @@ public static class Settings
         public const string QQ_GROUP_LINK = "https://qm.qq.com/cgi-bin/qm/qr?k=KcexYJ9aYwogFXbj2aN0XHH5b2G7ICmd";
         public const string EMAIL = "[email protected]";
         public const string AUHTOR = "psygames";
-        public const string VERSION = "2.6.0";
+        public const string VERSION = "2.6.1";
     }
 }

Assets/UnityWebSocket/Scripts/Runtime/Implementation/NoWebGL/WebSocket.cs

@@ -200,16 +200,17 @@ private async Task ReceiveTask()
             ushort closeCode = 0;
             bool isClosed = false;
             var segment = new ArraySegment<byte>(new byte[8192]);
-            var ms = new MemoryStream();
 
             try
             {
                 while (!IsCtsCanceled && !isClosed)
                 {
+                    var ms = new MemoryStream();
                     var result = await socket.ReceiveAsync(segment, cts.Token);
-                    ms.Write(segment.Array, segment.Offset, result.Count);
+                    ms.Write(segment.Array, 0, result.Count);
                     if (!result.EndOfMessage) continue;
                     var data = ms.ToArray();
+                    ms.Close();
                     switch (result.MessageType)
                     {
                         case WebSocketMessageType.Binary:
@@ -224,7 +225,6 @@ private async Task ReceiveTask()
                             closeReason = result.CloseStatusDescription;
                             break;
                     }
-                    ms.Seek(0, SeekOrigin.Begin);
                 }
             }
             catch (Exception e)
@@ -233,10 +233,6 @@ private async Task ReceiveTask()
                 closeCode = (ushort)CloseStatusCode.Abnormal;
                 closeReason = e.Message;
             }
-            finally
-            {
-                ms.Close();
-            }
 
             cts.Cancel();