WebSocket.SendAll时要阻塞等待，否则数据包被回收后无法使用

NewLifeX · Sep 11, 2024 · 5fb3e73 · 5fb3e73
1 parent 8f73218
commit 5fb3e73
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/NewLife.Core/Http/WebSocket.cs b/NewLife.Core/Http/WebSocket.cs
@@ -139,7 +139,7 @@ public void SendAll(IPacket data, WebSocketMessageType type, Func<INetSession, B
         var session = (Context?.Connection) ?? throw new ObjectDisposedException(nameof(Context));
         var msg = new WebSocketMessage { Type = type, Payload = data };
         using var data2 = msg.ToPacket();
-        session.Host.SendAllAsync(data2, predicate);
+        session.Host.SendAllAsync(data2, predicate).Wait();
     }
 
     /// <summary>想所有连接发送文本消息</summary>

diff --git a/NewLife.Core/Http/WebSocketMessage.cs b/NewLife.Core/Http/WebSocketMessage.cs
@@ -140,7 +140,7 @@ public virtual IOwnerPacket ToPacket()
             if (!StatusDescription.IsNullOrEmpty()) len += Encoding.UTF8.GetByteCount(StatusDescription);
         }
 
-        var rs = new OwnerPacket(1 + 1 + 8 + 4 + len);
+        var rs = new ArrayPacket(1 + 1 + 8 + 4 + len);
         var writer = new SpanWriter(rs.GetSpan())
         {
             IsLittleEndian = false