Skip to content

Commit f4c9725

Browse files
committed
Clear QpServer's Channels when stop.
1 parent c722956 commit f4c9725

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

Quick.Protocol.WebSocket.Server.AspNetCore/WebSocketServerStream.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,7 @@ internal class WebSocketServerStream : Stream
1212
{
1313
private System.Net.WebSockets.WebSocket webSocket;
1414
private CancellationToken cancellationToken;
15-
private const int ReadSize = 1024 * 4;
16-
private byte[] readBuffer = new byte[ReadSize];
17-
15+
1816
public WebSocketServerStream(System.Net.WebSockets.WebSocket webSocket, CancellationToken cancellationToken)
1917
{
2018
this.webSocket = webSocket;

Quick.Protocol/QpServer.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,11 @@ public virtual void Stop()
116116
{
117117
cts?.Cancel();
118118
cts = null;
119+
lock (channelList)
120+
{
121+
channelList.Clear();
122+
Channels = channelList.ToArray();
123+
}
119124
}
120125
}
121126
}

0 commit comments

Comments
 (0)