Add SSE disconnect logic

2024-08-27 16:40:36 +02:00
parent 1c60556cc8
commit 3dedc315ca
1 changed files with 7 additions and 1 deletions
@@ -36,7 +36,13 @@ public class SSEConnection
                if (!OutboundQueue.TryDequeue(out var outgoingEvent))
                    continue;

-                await ctx.Response.SendChunk(outgoingEvent.Build(), Token);
+                if (!await ctx.Response.SendChunk(outgoingEvent.Build(), Token))
+                {
+                    Plugin.Log.Information("SSE connection was unable to send new data");
+                    Plugin.Log.Information($"Client disconnected: {ctx.Guid}");
+                    return;
+                }
+
                Index++;
            }
        }