Many changes

Author: st0o0

src/TurboHTTP.Benchmarks/Internal/ClientHelper.cs

@@ -2,7 +2,6 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection.Extensions;
 using Microsoft.Extensions.Options;
-using TurboHTTP.Internal;
 
 namespace TurboHTTP.Benchmarks.Internal;
 

src/TurboHTTP.IntegrationTests/H10/ExpectContinueSpec.cs

@@ -1,8 +1,6 @@
 using System.Net;
 using System.Text;
-using Microsoft.Extensions.DependencyInjection;
 using TurboHTTP.IntegrationTests.Shared;
-using TurboHTTP.Protocol.Semantics;
 
 namespace TurboHTTP.IntegrationTests.H10;
 

src/TurboHTTP.IntegrationTests/H11/ExpectContinueSpec.cs

@@ -1,8 +1,6 @@
 using System.Net;
 using System.Text;
-using Microsoft.Extensions.DependencyInjection;
 using TurboHTTP.IntegrationTests.Shared;
-using TurboHTTP.Protocol.Semantics;
 
 namespace TurboHTTP.IntegrationTests.H11;
 

src/TurboHTTP.IntegrationTests/H2/ExpectContinueSpec.cs

@@ -1,8 +1,6 @@
 using System.Net;
 using System.Text;
-using Microsoft.Extensions.DependencyInjection;
 using TurboHTTP.IntegrationTests.Shared;
-using TurboHTTP.Protocol.Semantics;
 
 namespace TurboHTTP.IntegrationTests.H2;
 

src/TurboHTTP.IntegrationTests/LoggingBridgeSpec.cs

@@ -99,10 +99,8 @@ private ITurboHttpClient BuildClientViaUserDI(bool withTurboTrace = false)
         {
             var loggerFactory = sp.GetRequiredService<ILoggerFactory>();
             var diSetup = DependencyResolverSetup.Create(sp);
-            var dispatcherConfig = TurboHttpDispatchers.CreateConfig(
-                TurboClientOptions.DefaultMaxEndpointSubstreams);
             var setup = BootstrapSetup.Create()
-                .WithConfig(LoggingHocon.WithFallback(dispatcherConfig))
+                .WithConfig(LoggingHocon)
                 .And(diSetup)
                 .And(new LoggerFactorySetup(loggerFactory));
             return ActorSystem.Create("turbohttp-bridge-test", setup);

src/TurboHTTP.IntegrationTests/Shared/ActorSystemFixture.cs

@@ -1,6 +1,4 @@
 using Akka.Actor;
-using Akka.Actor.Setup;
-using Akka.Configuration;
 using Akka.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection;
 using TurboHTTP.Internal;
@@ -20,9 +18,7 @@ public ValueTask InitializeAsync()
     {
         var services = new ServiceCollection();
         var diSetup = DependencyResolverSetup.Create(services.BuildServiceProvider());
-        var dispatcherConfig = TurboHttpDispatchers.CreateConfig(
-            TurboClientOptions.DefaultMaxEndpointSubstreams);
-        var bootstrap = BootstrapSetup.Create().WithConfig(dispatcherConfig);
+        var bootstrap = BootstrapSetup.Create();
 
         var setup = bootstrap.And(diSetup);
         System = ActorSystem.Create($"turbohttp-shared-{Guid.NewGuid()}", setup);

src/TurboHTTP.IntegrationTests/Shared/ClientHelper.cs

@@ -66,14 +66,12 @@ public static ClientHelper CreateClient(
             // Create an ActorSystem with DependencyResolver so that Servus.Akka
             // ResolveActor<T> works inside TurboClientStreamManager.
             var diSetup = DependencyResolverSetup.Create(services.BuildServiceProvider());
-            var dispatcherConfig = TurboHttpDispatchers.CreateConfig(
-                TurboClientOptions.DefaultMaxEndpointSubstreams);
             var bootstrap = BootstrapSetup.Create();
 
             if (loggerFactory is not null)
-                bootstrap = bootstrap.WithConfig(LoggingHocon.WithFallback(dispatcherConfig));
-            else
-                bootstrap = bootstrap.WithConfig(dispatcherConfig);
+            {
+                bootstrap = bootstrap.WithConfig(LoggingHocon);
+            }
 
             var setup = loggerFactory is not null
                 ? bootstrap.And(diSetup).And(new LoggerFactorySetup(loggerFactory))

src/TurboHTTP.IntegrationTests/TLS/ExpectContinueSpec.cs

@@ -1,8 +1,6 @@
 using System.Net;
 using System.Text;
-using Microsoft.Extensions.DependencyInjection;
 using TurboHTTP.IntegrationTests.Shared;
-using TurboHTTP.Protocol.Semantics;
 
 namespace TurboHTTP.IntegrationTests.TLS;
 

src/TurboHTTP.StreamTests/Dispatchers/DispatcherConfigurationSpec.cs

@@ -164,7 +164,7 @@ public async Task Http10ConnectionStage_should_not_reconnect_when_no_inflight_re
 
         // Stage should NOT emit a ReconnectItem — verify no output within 200ms
         await Task.Delay(200, TestContext.Current.CancellationToken);
-        networkSub.ExpectNoMsg(TimeSpan.Zero);
+        networkSub.ExpectNoMsg(TimeSpan.Zero, TestContext.Current.CancellationToken);
 
         // Upstream completes → stage completes
         serverSub.SendComplete();