From c2f63db3add78ffc77b0a9117ac8eabb56b81238 Mon Sep 17 00:00:00 2001 From: KyuubiYoru Date: Fri, 17 Jul 2026 00:34:29 +0200 Subject: [PATCH] test(client): stabilize stream integration gate (#1) --- .../Client/RendezvousClientIntegrationTests.cs | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/tests/FinalFactory.Rendezvous.Tests/Client/RendezvousClientIntegrationTests.cs b/tests/FinalFactory.Rendezvous.Tests/Client/RendezvousClientIntegrationTests.cs index 87515f7..61c7e6c 100644 --- a/tests/FinalFactory.Rendezvous.Tests/Client/RendezvousClientIntegrationTests.cs +++ b/tests/FinalFactory.Rendezvous.Tests/Client/RendezvousClientIntegrationTests.cs @@ -147,7 +147,12 @@ public sealed class RendezvousClientIntegrationTests { await using ClientTestHost host = await ClientTestHost.StartAsync(); RendezvousPublisherClient publisher = new(host.HttpClient); - RendezvousSessionBrowserClient browser = new(host.HttpClient); + RendezvousSessionBrowserClient browser = new( + host.HttpClient, + new RendezvousClientOptions + { + RequestTimeout = TimeSpan.FromSeconds(15), + }); PublishedSession session = AssertSuccess(await publisher.RegisterAsync( CreateRegistration(200), host.PublisherCredential)); @@ -156,7 +161,7 @@ public sealed class RendezvousClientIntegrationTests BrowseSessionsResponse snapshot = AssertSuccess(await browser.BrowseAsync(request)); Assert.False(string.IsNullOrWhiteSpace(snapshot.StreamCursor)); - using CancellationTokenSource timeout = new(TimeSpan.FromSeconds(10)); + using CancellationTokenSource timeout = new(TimeSpan.FromSeconds(30)); await using (IAsyncEnumerator> invalid = browser .StreamAsync(request, CorruptCursor(snapshot.StreamCursor), timeout.Token) .GetAsyncEnumerator(timeout.Token))