Use larger buffer in for PipeReader

Author: ericstj

src/ModelContextProtocol.Core/Client/StreamClientSessionTransport.cs

@@ -10,6 +10,7 @@ namespace ModelContextProtocol.Client;
 internal class StreamClientSessionTransport : TransportBase
 {
     private static readonly byte[] s_newlineBytes = "\n"u8.ToArray();
+    private static readonly StreamPipeReaderOptions s_pipeReaderOptions = new(bufferSize: 64 * 1024);  // 64KB minimum buffer
 
     private readonly PipeReader _serverOutputPipe;
     private readonly Stream _serverInputStream;
@@ -43,7 +44,7 @@ public StreamClientSessionTransport(Stream serverInput, Stream serverOutput, str
         Throw.IfNull(serverOutput);
 
         _serverInputStream = serverInput;
-        _serverOutputPipe = PipeReader.Create(serverOutput);
+        _serverOutputPipe = PipeReader.Create(serverOutput, s_pipeReaderOptions);
 
         SetConnected();
 

src/ModelContextProtocol.Core/Server/StreamServerTransport.cs

@@ -18,6 +18,7 @@ namespace ModelContextProtocol.Server;
 public class StreamServerTransport : TransportBase
 {
     private static readonly byte[] s_newlineBytes = "\n"u8.ToArray();
+    private static readonly StreamPipeReaderOptions s_pipeReaderOptions = new(bufferSize: 64 * 1024);  // 64KB minimum buffer
 
     private readonly ILogger _logger;
 
@@ -48,7 +49,7 @@ public StreamServerTransport(Stream inputStream, Stream outputStream, string? se
         _logger = loggerFactory?.CreateLogger(GetType()) ?? NullLogger.Instance;
 
         _inputStream = inputStream;
-        _inputPipeReader = PipeReader.Create(inputStream);
+        _inputPipeReader = PipeReader.Create(inputStream, s_pipeReaderOptions);
         _outputStream = outputStream;
 
         SetConnected();