fix(h3): wire MaxConnectionsPerServer and MaxConcurrentStreams to QUIC transport

Author: st0o0

src/TurboHTTP/Internal/OptionsFactory.cs

@@ -38,6 +38,8 @@ internal static TransportOptions Build(RequestEndpoint endpoint, TurboClientOpti
                 SocketReceiveBufferSize = clientOptions.SocketReceiveBufferSize,
                 AllowConnectionMigration = clientOptions.Http3.AllowConnectionMigration,
                 IdleTimeout = clientOptions.Http3.IdleTimeout,
+                MaxConnectionsPerHost = clientOptions.Http3.MaxConnectionsPerServer,
+                MaxBidirectionalStreams = clientOptions.Http3.MaxConcurrentStreams,
                 ApplicationProtocols = alpn,
                 AutoReconnect = true,
                 ConnectionLifetime = clientOptions.PooledConnectionLifetime

src/TurboHTTP/Streams/Http10Engine.cs

@@ -6,20 +6,13 @@
 
 namespace TurboHTTP.Streams;
 
-internal class Http10Engine : IHttpProtocolEngine
+internal class Http10Engine(TurboClientOptions options) : IHttpProtocolEngine
 {
-    private readonly TurboClientOptions _options;
-
-    public Http10Engine(TurboClientOptions options)
-    {
-        _options = options;
-    }
-
     public BidiFlow<HttpRequestMessage, ITransportOutbound, ITransportInbound, HttpResponseMessage, NotUsed> CreateFlow()
     {
         return BidiFlow.FromGraph(GraphDsl.Create(b =>
         {
-            var connection = b.Add(new Http10ConnectionStage(_options));
+            var connection = b.Add(new Http10ConnectionStage(options));
 
             return new BidiShape<
                 HttpRequestMessage,

src/TurboHTTP/Streams/Http11Engine.cs

@@ -6,21 +6,13 @@
 
 namespace TurboHTTP.Streams;
 
-internal class Http11Engine : IHttpProtocolEngine
+internal class Http11Engine(TurboClientOptions options) : IHttpProtocolEngine
 {
-    private readonly TurboClientOptions _options;
-
-
-    public Http11Engine(TurboClientOptions options)
-    {
-        _options = options;
-    }
-
     public BidiFlow<HttpRequestMessage, ITransportOutbound, ITransportInbound, HttpResponseMessage, NotUsed> CreateFlow()
     {
         return BidiFlow.FromGraph(GraphDsl.Create(b =>
         {
-            var connection = b.Add(new Http11ConnectionStage(_options));
+            var connection = b.Add(new Http11ConnectionStage(options));
 
             return new BidiShape<
                 HttpRequestMessage,

src/TurboHTTP/Streams/Http20Engine.cs

@@ -6,20 +6,13 @@
 
 namespace TurboHTTP.Streams;
 
-internal class Http20Engine : IHttpProtocolEngine
+internal class Http20Engine(TurboClientOptions options) : IHttpProtocolEngine
 {
-    private readonly TurboClientOptions _options;
-
-    public Http20Engine(TurboClientOptions options)
-    {
-        _options = options;
-    }
-
     public BidiFlow<HttpRequestMessage, ITransportOutbound, ITransportInbound, HttpResponseMessage, NotUsed> CreateFlow()
     {
         return BidiFlow.FromGraph(GraphDsl.Create(b =>
         {
-            var connection = b.Add(new Http20ConnectionStage(_options));
+            var connection = b.Add(new Http20ConnectionStage(options));
 
             return new BidiShape<
                 HttpRequestMessage,

src/TurboHTTP/Streams/Http30Engine.cs

@@ -6,20 +6,13 @@
 
 namespace TurboHTTP.Streams;
 
-internal sealed class Http30Engine : IHttpProtocolEngine
+internal sealed class Http30Engine(TurboClientOptions options) : IHttpProtocolEngine
 {
-    private readonly TurboClientOptions _options;
-
-    public Http30Engine(TurboClientOptions options)
-    {
-        _options = options;
-    }
-
     public BidiFlow<HttpRequestMessage, ITransportOutbound, ITransportInbound, HttpResponseMessage, NotUsed> CreateFlow()
     {
         return BidiFlow.FromGraph(GraphDsl.Create(b =>
         {
-            var connection = b.Add(new Http30ConnectionStage(_options));
+            var connection = b.Add(new Http30ConnectionStage(options));
 
             return new BidiShape<
                 HttpRequestMessage,

src/TurboHTTP/Streams/ProtocolCoreBuilder.cs

@@ -45,7 +45,7 @@ internal static Flow<HttpRequestMessage, HttpResponseMessage, NotUsed> Build(
         return core.WithAttributes(highThroughputBuffer);
 
         int MaxConcurrencyPerSlot(RequestEndpoint endpoint)
-            => GetMaxConcurrencyPerSlot(endpoint, h2Streams, clientOptions.Http1.MaxPipelineDepth, h3Streams);
+            => GetMaxConcurrencyPerSlot(endpoint, clientOptions.Http1.MaxPipelineDepth, h2Streams, h3Streams);
 
         int MaxSubstreamsPerKey(RequestEndpoint endpoint)
             => GetMaxSubstreamsPerKey(endpoint, maxConnsH1, maxConnsH2, maxConnsH3);
@@ -72,7 +72,7 @@ Flow<HttpRequestMessage, HttpResponseMessage, NotUsed> CreateFlowForEndpoint(Req
         }
     }
 
-    internal static int GetMaxConcurrencyPerSlot(RequestEndpoint endpoint, int h2Streams, int h1Streams, int h3Streams)
+    internal static int GetMaxConcurrencyPerSlot(RequestEndpoint endpoint, int h1Streams, int h2Streams, int h3Streams)
     {
         return endpoint.Version switch
         {

src/TurboHTTP/TurboClientOptions.cs

@@ -30,13 +30,13 @@ public sealed class TurboClientOptions
     public Uri? BaseAddress { get; set; }
 
     /// <summary>HTTP/1.x-specific configuration.</summary>
-    public Http1Options Http1 { get; set; } = new();
+    public Http1Options Http1 { get; init; } = new();
 
     /// <summary>HTTP/2-specific configuration.</summary>
-    public Http2Options Http2 { get; set; } = new();
+    public Http2Options Http2 { get; init; } = new();
 
     /// <summary>HTTP/3-specific configuration.</summary>
-    public Http3Options Http3 { get; set; } = new();
+    public Http3Options Http3 { get; init; } = new();
 
     /// <summary>
     /// Timeout for establishing a new TCP connection.