Skip flaky net8 SSE fallback test in CI

Author: ANcpLua

SWEN3.Paperless.RabbitMq.Tests/Unit/SseExtensionsFallbackTests.cs

@@ -33,27 +33,45 @@ public async Task MapSse_OnNet8_ShouldWriteCorrectSseFormat()
         using var cts = CancellationTokenSource.CreateLinkedTokenSource(TestContext.Current.CancellationToken);
         cts.CancelAfter(TimeSpan.FromSeconds(10));
 
-        using var response = await client.GetAsync("/sse", HttpCompletionOption.ResponseHeadersRead, cts.Token);
-        response.EnsureSuccessStatusCode();
-        await using var stream = await response.Content.ReadAsStreamAsync(cts.Token);
-        using var reader = new StreamReader(stream, Encoding.UTF8);
+        var responseTask = client.GetAsync("/sse", HttpCompletionOption.ResponseHeadersRead, cts.Token);
 
-        string? line1 = null;
-        string? line2 = null;
-        string? line3 = null;
+        // Publish repeatedly until the subscriber is definitely connected
+        var publisherTask = Task.Run(async () =>
+        {
+            try
+            {
+                while (!cts.Token.IsCancellationRequested)
+                {
+                    await Task.Delay(50, cts.Token);
+                    sseStream.Publish(new Messages.SseTestEvent { Id = 1, Message = "Hello" });
+                }
+            }
+            catch (OperationCanceledException)
+            {
+                // Expected when the test ends
+            }
+        }, CancellationToken.None);
 
-        for (var i = 0; i < 50 && line1 is null; i++)
+        try
         {
-            sseStream.Publish(new Messages.SseTestEvent { Id = 1, Message = "Hello" });
-            line1 = await reader.ReadLineAsync(cts.Token);
-        }
+            using var response = await responseTask;
+            response.EnsureSuccessStatusCode();
+            await using var stream = await response.Content.ReadAsStreamAsync(cts.Token);
+            using var reader = new StreamReader(stream, Encoding.UTF8);
 
-        line2 = await reader.ReadLineAsync(cts.Token);
-        line3 = await reader.ReadLineAsync(cts.Token);
+            var line1 = await reader.ReadLineAsync(cts.Token);
+            var line2 = await reader.ReadLineAsync(cts.Token);
+            var line3 = await reader.ReadLineAsync(cts.Token);
 
-        line1.Should().Be("event: test-event");
-        line2.Should().Be("data: {\"id\":1,\"msg\":\"Hello\"}");
-        line3.Should().BeEmpty(); // The double newline
+            line1.Should().Be("event: test-event");
+            line2.Should().Be("data: {\"id\":1,\"msg\":\"Hello\"}");
+            line3.Should().BeEmpty(); // The double newline
+        }
+        finally
+        {
+            cts.Cancel();
+            await publisherTask;
+        }
     }
 #endif
 }