whitespace fixes

Author: halter73

src/ModelContextProtocol/Client/AutoDetectingClientSessionTransport.cs

@@ -65,24 +65,25 @@ private async Task InitializeAsync(JsonRpcMessage message, CancellationToken can
         {
             LogAttemptingStreamableHttp(_name);
             using var response = await streamableHttpTransport.SendHttpRequestAsync(message, cancellationToken).ConfigureAwait(false);
-            
-            // If the status code is not success, fall back to SSE
-            if (!response.IsSuccessStatusCode)
+
+            if (response.IsSuccessStatusCode)
+            {
+                LogUsingStreamableHttp(_name);
+                ActiveTransport = streamableHttpTransport;
+            }
+            else
             {
+                // If the status code is not success, fall back to SSE
                 LogStreamableHttpFailed(_name, response.StatusCode);
-                
+
                 await streamableHttpTransport.DisposeAsync().ConfigureAwait(false);
                 await InitializeSseTransportAsync(message, cancellationToken).ConfigureAwait(false);
-                return;
             }
-            
-            LogUsingStreamableHttp(_name);
-            ActiveTransport = streamableHttpTransport;
         }
         catch
         {
             // If nothing threw inside the try block, we've either set streamableHttpTransport as the
-            // ActiveTransport, or else we will have disposed it in the !IsSuccessStatusCode if statement.
+            // ActiveTransport, or else we will have disposed it in the !IsSuccessStatusCode else block.
             await streamableHttpTransport.DisposeAsync().ConfigureAwait(false);
             throw;
         }
@@ -97,7 +98,7 @@ private async Task InitializeSseTransportAsync(JsonRpcMessage message, Cancellat
             LogAttemptingSSE(_name);
             await sseTransport.ConnectAsync(cancellationToken).ConfigureAwait(false);
             await sseTransport.SendMessageAsync(message, cancellationToken).ConfigureAwait(false);
-            
+
             LogUsingSSE(_name);
             ActiveTransport = sseTransport;
         }
@@ -124,7 +125,7 @@ public async ValueTask DisposeAsync()
             _messageChannel.Writer.TryComplete();
         }
     }
-    
+
     [LoggerMessage(Level = LogLevel.Debug, Message = "{EndpointName} attempting to connect using Streamable HTTP transport.")]
     private partial void LogAttemptingStreamableHttp(string endpointName);
 
@@ -133,10 +134,10 @@ public async ValueTask DisposeAsync()
 
     [LoggerMessage(Level = LogLevel.Information, Message = "{EndpointName} using Streamable HTTP transport.")]
     private partial void LogUsingStreamableHttp(string endpointName);
-    
+
     [LoggerMessage(Level = LogLevel.Debug, Message = "{EndpointName} attempting to connect using SSE transport.")]
     private partial void LogAttemptingSSE(string endpointName);
-    
+
     [LoggerMessage(Level = LogLevel.Information, Message = "{EndpointName} using SSE transport.")]
     private partial void LogUsingSSE(string endpointName);
 }

src/ModelContextProtocol/Client/SseClientTransport.cs

@@ -36,7 +36,7 @@ public SseClientTransport(SseClientTransportOptions transportOptions, ILoggerFac
     /// <param name="httpClient">The HTTP client instance used for requests.</param>
     /// <param name="loggerFactory">Logger factory for creating loggers used for diagnostic output during transport operations.</param>
     /// <param name="ownsHttpClient">
-    /// <see langword="true"/> to dispose of <paramref name="httpClient"/> when the transport is disposed; 
+    /// <see langword="true"/> to dispose of <paramref name="httpClient"/> when the transport is disposed;
     /// <see langword="false"/> if the caller is retaining ownership of the <paramref name="httpClient"/>'s lifetime.
     /// </param>
     public SseClientTransport(SseClientTransportOptions transportOptions, HttpClient httpClient, ILoggerFactory? loggerFactory = null, bool ownsHttpClient = false)

src/ModelContextProtocol/Client/StreamableHttpClientSessionTransport.cs

@@ -86,7 +86,7 @@ internal async Task<HttpResponseMessage> SendHttpRequestAsync(JsonRpcMessage mes
         };
 
         CopyAdditionalHeaders(httpRequestMessage.Headers, _options.AdditionalHeaders, _mcpSessionId);
-        
+
         var response = await _httpClient.SendAsync(httpRequestMessage, HttpCompletionOption.ResponseHeadersRead, cancellationToken).ConfigureAwait(false);
 
         // We'll let the caller decide whether to throw or fall back given an unsuccessful response.

src/ModelContextProtocol/Protocol/TransportBase.cs

@@ -120,7 +120,7 @@ protected void SetConnected()
 
                 case StateConnected:
                     return;
-                
+
                 case StateDisconnected:
                     throw new IOException("Transport is already disconnected and can't be reconnected.");
 

tests/ModelContextProtocol.AspNetCore.Tests/HttpServerIntegrationTests.cs

@@ -56,7 +56,7 @@ public async Task Connect_TestServer_ShouldProvideServerFields()
 
     [Fact]
     public async Task ListTools_Sse_TestServer()
-    {        
+    {
         // arrange
 
         // act