oops, forgot to use the pipe options!

StackExchange.Redis/StackExchange/Redis/PhysicalConnection.cs

@@ -835,7 +835,7 @@ private static LocalCertificateSelectionCallback GetAmbientCertificateCallback()
             return null;
         }
 
-        async ValueTask<SocketMode> ISocketCallback.ConnectedAsync(Socket socket, TextWriter log)
+        async ValueTask<SocketMode> ISocketCallback.ConnectedAsync(Socket socket, TextWriter log, PipeOptions pipeOptions)
         {
             try
             {
@@ -871,11 +871,11 @@ async ValueTask<SocketMode> ISocketCallback.ConnectedAsync(Socket socket, TextWr
                         Multiplexer.Trace("Encryption failure");
                         return SocketMode.Abort;
                     }
-                    pipe = StreamConnector.GetDuplex(ssl, name: Bridge.Name);
+                    pipe = StreamConnector.GetDuplex(ssl, pipeOptions, name: Bridge.Name);
                 }
                 else
                 {
-                    pipe = SocketConnection.Create(socket, name: Bridge.Name);
+                    pipe = SocketConnection.Create(socket, pipeOptions, name: Bridge.Name);
                 }
                 OnWrapForLogging(ref pipe, physicalName);
 

StackExchange.Redis/StackExchange/Redis/SocketManager.cs

@@ -28,7 +28,8 @@ internal partial interface ISocketCallback
         /// </summary>
         /// <param name="socket">The socket.</param>
         /// <param name="log">A text logger to write to.</param>
-        ValueTask<SocketMode> ConnectedAsync(Socket socket, TextWriter log);
+        /// <param name="pipeOptions">Pipe configuration</param>
+        ValueTask<SocketMode> ConnectedAsync(Socket socket, TextWriter log, PipeOptions pipeOptions);
 
         /// <summary>
         /// Indicates that the socket has signalled an error condition
@@ -147,7 +148,7 @@ public SocketManager(string name, bool useHighPrioritySocketThreads)
         }
         readonly DedicatedThreadPoolPipeScheduler _scheduler;
         readonly PipeOptions _pipeOptions;
-        
+
         private readonly Func<Task> _writeOneQueueAsync;
 
 
@@ -274,7 +275,7 @@ private async void EndConnectImpl(IAsyncResult ar, ConnectionMultiplexer multipl
                 if (ignoreConnect) return;
                 socket.EndConnect(ar);
 
-                var socketMode = callback == null ? SocketMode.Abort : await callback.ConnectedAsync(socket, log);
+                var socketMode = callback == null ? SocketMode.Abort : await callback.ConnectedAsync(socket, log, _pipeOptions);
                 switch (socketMode)
                 {
                     case SocketMode.Async: