- Swap Queue to ConcurrentQueue

2026-03-22 15:03:37 +01:00
parent 4341035c74
commit 9f7a6267f6
3 changed files with 4 additions and 4 deletions
@@ -1,4 +1,5 @@
-using ChatTwo.Http.MessageProtocol;
+using System.Collections.Concurrent;
+using ChatTwo.Http.MessageProtocol;
 using WatsonWebserver.Core;

 namespace ChatTwo.Http;
@@ -9,7 +10,7 @@ public class SSEConnection
    private readonly CancellationToken Token;

    public bool Done;
-    public readonly Queue<BaseEvent> OutboundQueue = new();
+    public readonly ConcurrentQueue<BaseEvent> OutboundQueue = new();

    public SSEConnection(CancellationToken token)
    {