diff --git a/src/Fluxzy.Core/Clients/PoolBuilder.cs b/src/Fluxzy.Core/Clients/PoolBuilder.cs index ba3444f82..3ee377c1d 100644 --- a/src/Fluxzy.Core/Clients/PoolBuilder.cs +++ b/src/Fluxzy.Core/Clients/PoolBuilder.cs @@ -121,9 +121,14 @@ public async ValueTask 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) {