fix ws issue

2023-03-26 13:21:46 +07:00
parent a73610c83b
commit ed61b0b348
3 changed files with 3 additions and 7 deletions
--- a/TorchRemote.Plugin/Modules/ChatModule.cs
+++ b/TorchRemote.Plugin/Modules/ChatModule.cs
@@ -17,9 +17,7 @@ public class ChatModule : WebSocketModule
            return;

        var buffer = JsonSerializer.SerializeToUtf8Bytes(response, Statics.SerializerOptions);
-        await Task.WhenAll(ActiveContexts
-            .Where(b => b.WebSocket.State is WebSocketState.Open)
-            .Select(context => context.WebSocket.SendAsync(buffer, true)));
+        await BroadcastAsync(buffer);
    }
    
    protected override async Task OnMessageReceivedAsync(IWebSocketContext context, byte[] buffer, IWebSocketReceiveResult result)