Force PoolBuilder to create a new connection when incoming request …

…is a websocket upgrade #265
haga-rak · May 23, 2024 · 251c9c4 · 251c9c4
1 parent bfd06a2
commit 251c9c4
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/Fluxzy.Core/Clients/PoolBuilder.cs b/src/Fluxzy.Core/Clients/PoolBuilder.cs
@@ -121,9 +121,14 @@ public async ValueTask<IHttpConnectionPool>
                 if (!semaphorePerAuthority.Wait(0))
                     await semaphorePerAuthority.WaitAsync(cancellationToken).ConfigureAwait(false);
 
+                var forceNewConnection = exchange.Context.ForceNewConnection;
+
+                if (exchange.Request.Header.IsWebSocketRequest || exchange.Context.BlindMode)
+                    forceNewConnection = true;
+
                 // Looking for existing HttpPool
 
-                if (!exchange.Context.ForceNewConnection) {
+                if (!forceNewConnection) {
                     lock (_connectionPools) {
                         while (_connectionPools.TryGetValue(exchange.Authority, out var pool)) {
                             if (pool.Complete) {