feat(tests): configure xunit parallelization and timeouts

st0o0 · st0o0 · commit 143003f207ae · 2026-05-10T23:14:26.000+02:00
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -59,6 +59,7 @@ jobs:
           --coverage
           --coverage-output-format cobertura
           --results-directory ${{ env.TEST_OUTPUT_DIRECTORY }}
+          --max-parallel-test-modules 2
           --solution *.slnx
 
       - name: Report Code Coverage
diff --git a/src/Servus.Akka.TestKit.Tests/Servus.Akka.TestKit.Tests.csproj b/src/Servus.Akka.TestKit.Tests/Servus.Akka.TestKit.Tests.csproj
@@ -21,4 +21,10 @@
         <ProjectReference Include="..\Servus.Akka.TestKit\Servus.Akka.TestKit.csproj"/>
     </ItemGroup>
 
+    <ItemGroup>
+        <Content Include="xunit.runner.json">
+            <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+        </Content>
+    </ItemGroup>
+
 </Project>
diff --git a/src/Servus.Akka.TestKit.Tests/xunit.runner.json b/src/Servus.Akka.TestKit.Tests/xunit.runner.json
@@ -0,0 +1,6 @@
+{
+  "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
+  "parallelizeTestCollections": true,
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
+}
diff --git a/src/Servus.Akka.Tests/Servus.Akka.Tests.csproj b/src/Servus.Akka.Tests/Servus.Akka.Tests.csproj
@@ -22,4 +22,10 @@
         <ProjectReference Include="..\Servus.Akka\Servus.Akka.csproj"/>
     </ItemGroup>
 
+    <ItemGroup>
+        <Content Include="xunit.runner.json">
+            <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+        </Content>
+    </ItemGroup>
+
 </Project>
diff --git a/src/Servus.Akka.Tests/xunit.runner.json b/src/Servus.Akka.Tests/xunit.runner.json
@@ -0,0 +1,6 @@
+{
+  "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
+  "parallelizeTestCollections": true,
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
+}
diff --git a/src/TurboHTTP.AcceptanceTests/TurboHTTP.AcceptanceTests.csproj b/src/TurboHTTP.AcceptanceTests/TurboHTTP.AcceptanceTests.csproj
@@ -21,4 +21,10 @@
         <ProjectReference Include="..\TurboHTTP\TurboHTTP.csproj"/>
     </ItemGroup>
 
+    <ItemGroup>
+        <Content Include="xunit.runner.json">
+            <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+        </Content>
+    </ItemGroup>
+
 </Project>
diff --git a/src/TurboHTTP.AcceptanceTests/xunit.runner.json b/src/TurboHTTP.AcceptanceTests/xunit.runner.json
@@ -0,0 +1,6 @@
+{
+  "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
+  "parallelizeTestCollections": true,
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
+}
diff --git a/src/TurboHTTP.IntegrationTests.Container/xunit.runner.json b/src/TurboHTTP.IntegrationTests.Container/xunit.runner.json
@@ -1,5 +1,6 @@
 {
   "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
   "parallelizeTestCollections": true,
-  "parallelizeAssembly": false
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
 }
diff --git a/src/TurboHTTP.IntegrationTests.Kestrel/xunit.runner.json b/src/TurboHTTP.IntegrationTests.Kestrel/xunit.runner.json
@@ -1,5 +1,6 @@
 {
   "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
   "parallelizeTestCollections": true,
-  "parallelizeAssembly": false
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
 }
diff --git a/src/TurboHTTP.Tests/Client/NamedClientRuntimeSpec.cs b/src/TurboHTTP.Tests/Client/NamedClientRuntimeSpec.cs
@@ -7,7 +7,7 @@ namespace TurboHTTP.Tests.Client;
 
 public sealed class NamedClientRuntimeSpec
 {
-    [Fact(Timeout = 5000)]
+    [Fact(Timeout = 15000)]
     public async Task CreateClient_same_name_should_reuse_single_named_runtime()
     {
         const string name = "shared-runtime";
@@ -33,7 +33,7 @@ public async Task CreateClient_same_name_should_reuse_single_named_runtime()
         }
         finally
         {
-            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);
+            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);
         }
     }
 
@@ -75,11 +75,11 @@ public async Task CreateClient_concurrent_same_name_should_reuse_single_named_ru
         }
         finally
         {
-            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);
+            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);
         }
     }
 
-    [Fact(Timeout = 5000)]
+    [Fact(Timeout = 15000)]
     public async Task CreateClient_different_names_should_not_share_named_runtime()
     {
         const string firstName = "runtime-a";
@@ -107,11 +107,11 @@ public async Task CreateClient_different_names_should_not_share_named_runtime()
         }
         finally
         {
-            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);
+            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);
         }
     }
 
-    [Fact(Timeout = 5000)]
+    [Fact(Timeout = 15000)]
     public async Task CreateClient_shared_runtime_should_apply_named_base_address_defaults()
     {
         const string name = "named-defaults";
@@ -137,11 +137,11 @@ public async Task CreateClient_shared_runtime_should_apply_named_base_address_de
         }
         finally
         {
-            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);
+            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);
         }
     }
 
-    [Fact(Timeout = 5000)]
+    [Fact(Timeout = 15000)]
     public async Task CreateClient_should_create_named_consumer_registration()
     {
         const string name = "registration-test";
@@ -164,7 +164,7 @@ public async Task CreateClient_should_create_named_consumer_registration()
         }
         finally
         {
-            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);
+            await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);
         }
     }
 
diff --git a/src/TurboHTTP.Tests/TurboHTTP.Tests.csproj b/src/TurboHTTP.Tests/TurboHTTP.Tests.csproj
@@ -18,4 +18,10 @@
         <ProjectReference Include="..\TurboHTTP.Tests.Shared\TurboHTTP.Tests.Shared.csproj" />
     </ItemGroup>
 
+    <ItemGroup>
+        <Content Include="xunit.runner.json">
+            <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+        </Content>
+    </ItemGroup>
+
 </Project>
diff --git a/src/TurboHTTP.Tests/xunit.runner.json b/src/TurboHTTP.Tests/xunit.runner.json
@@ -0,0 +1,6 @@
+{
+  "$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",
+  "parallelizeTestCollections": true,
+  "parallelizeAssembly": false,
+  "maxParallelThreads": 2
+}
diff --git a/src/TurboHTTP/Streams/Stages/Features/CacheBidiStage.cs b/src/TurboHTTP/Streams/Stages/Features/CacheBidiStage.cs
@@ -478,7 +478,6 @@ private HttpResponseMessage ProcessResponse(HttpResponseMessage response)
                 success: result => result,
                 failure: ex => new BodyReadFailed(
                     ex.GetBaseException()));
-            return response;
         }
 
         return response;
@@ -520,7 +519,7 @@ private void InvalidateIfSameOrigin(Uri requestUri, Uri? targetUri)
 
     private static async Task<BodyReadComplete> ReadBodyToPoolAsync(HttpResponseMessage response)
     {
-        await using var stream = await response.Content.ReadAsStreamAsync().ConfigureAwait(false);
+        await using var stream = await response.Content.ReadAsStreamAsync();
         var length = (int)stream.Length;
         var owner = MemoryPool<byte>.Shared.Rent(length);
         stream.ReadExactly(owner.Memory.Span[..length]);

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"$schema": "https://xunit.net/schema/current/xunit.runner.schema.json",`
`3`	`3`	`"parallelizeTestCollections": true,`
`4`		`- "parallelizeAssembly": false`
	`4`	`+ "parallelizeAssembly": false,`
	`5`	`+ "maxParallelThreads": 2`
`5`	`6`	`}`
Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@ namespace TurboHTTP.Tests.Client;`
`7`	`7`
`8`	`8`	`public sealed class NamedClientRuntimeSpec`
`9`	`9`	`{`
`10`		`- [Fact(Timeout = 5000)]`
	`10`	`+ [Fact(Timeout = 15000)]`
`11`	`11`	`public async Task CreateClient_same_name_should_reuse_single_named_runtime()`
`12`	`12`	`{`
`13`	`13`	`const string name = "shared-runtime";`
`@@ -33,7 +33,7 @@ public async Task CreateClient_same_name_should_reuse_single_named_runtime()`
`33`	`33`	`}`
`34`	`34`	`finally`
`35`	`35`	`{`
`36`		`- await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);`
	`36`	`+ await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);`
`37`	`37`	`}`
`38`	`38`	`}`
`39`	`39`
`@@ -75,11 +75,11 @@ public async Task CreateClient_concurrent_same_name_should_reuse_single_named_ru`
`75`	`75`	`}`
`76`	`76`	`finally`
`77`	`77`	`{`
`78`		`- await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);`
	`78`	`+ await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);`
`79`	`79`	`}`
`80`	`80`	`}`
`81`	`81`
`82`		`- [Fact(Timeout = 5000)]`
	`82`	`+ [Fact(Timeout = 15000)]`
`83`	`83`	`public async Task CreateClient_different_names_should_not_share_named_runtime()`
`84`	`84`	`{`
`85`	`85`	`const string firstName = "runtime-a";`
`@@ -107,11 +107,11 @@ public async Task CreateClient_different_names_should_not_share_named_runtime()`
`107`	`107`	`}`
`108`	`108`	`finally`
`109`	`109`	`{`
`110`		`- await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);`
	`110`	`+ await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);`
`111`	`111`	`}`
`112`	`112`	`}`
`113`	`113`
`114`		`- [Fact(Timeout = 5000)]`
	`114`	`+ [Fact(Timeout = 15000)]`
`115`	`115`	`public async Task CreateClient_shared_runtime_should_apply_named_base_address_defaults()`
`116`	`116`	`{`
`117`	`117`	`const string name = "named-defaults";`
`@@ -137,11 +137,11 @@ public async Task CreateClient_shared_runtime_should_apply_named_base_address_de`
`137`	`137`	`}`
`138`	`138`	`finally`
`139`	`139`	`{`
`140`		`- await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);`
	`140`	`+ await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);`
`141`	`141`	`}`
`142`	`142`	`}`
`143`	`143`
`144`		`- [Fact(Timeout = 5000)]`
	`144`	`+ [Fact(Timeout = 15000)]`
`145`	`145`	`public async Task CreateClient_should_create_named_consumer_registration()`
`146`	`146`	`{`
`147`	`147`	`const string name = "registration-test";`
`@@ -164,7 +164,7 @@ public async Task CreateClient_should_create_named_consumer_registration()`
`164`	`164`	`}`
`165`	`165`	`finally`
`166`	`166`	`{`
`167`		`- await system.Terminate().WaitAsync(TimeSpan.FromSeconds(5), TestContext.Current.CancellationToken);`
	`167`	`+ await system.Terminate().WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken);`
`168`	`168`	`}`
`169`	`169`	`}`
`170`	`170`