SseClientTransport -> HttpClientTransport

MackinnonBuck · MackinnonBuck · commit 4d426d076171 · 2025-09-03T09:53:46.000-05:00
diff --git a/samples/ProtectedMcpClient/Program.cs b/samples/ProtectedMcpClient/Program.cs
@@ -25,7 +25,7 @@
     builder.AddConsole();
 });
 
-var transport = new SseClientTransport(new()
+var transport = new HttpClientTransport(new()
 {
     Endpoint = new Uri(serverUrl),
     Name = "Secure Weather Client",
diff --git a/samples/QuickstartClient/Program.cs b/samples/QuickstartClient/Program.cs
@@ -19,7 +19,7 @@
 if (command == "http")
 {
     // make sure AspNetCoreMcpServer is running
-    clientTransport = new SseClientTransport(new()
+    clientTransport = new HttpClientTransport(new()
     {
         Endpoint = new Uri("http://localhost:3001")
     });
diff --git a/src/ModelContextProtocol.Core/Client/AutoDetectingClientSessionTransport.cs b/src/ModelContextProtocol.Core/Client/AutoDetectingClientSessionTransport.cs
@@ -12,14 +12,14 @@ namespace ModelContextProtocol.Client;
 /// </summary>
 internal sealed partial class AutoDetectingClientSessionTransport : ITransport
 {
-    private readonly SseClientTransportOptions _options;
+    private readonly HttpClientTransportOptions _options;
     private readonly McpHttpClient _httpClient;
     private readonly ILoggerFactory? _loggerFactory;
     private readonly ILogger _logger;
     private readonly string _name;
     private readonly Channel<JsonRpcMessage> _messageChannel;
 
-    public AutoDetectingClientSessionTransport(string endpointName, SseClientTransportOptions transportOptions, McpHttpClient httpClient, ILoggerFactory? loggerFactory)
+    public AutoDetectingClientSessionTransport(string endpointName, HttpClientTransportOptions transportOptions, McpHttpClient httpClient, ILoggerFactory? loggerFactory)
     {
         Throw.IfNull(transportOptions);
         Throw.IfNull(httpClient);
diff --git a/src/ModelContextProtocol.Core/Client/HttpClientTransport.cs b/src/ModelContextProtocol.Core/Client/HttpClientTransport.cs
@@ -13,26 +13,26 @@ namespace ModelContextProtocol.Client;
 /// Unlike the <see cref="StdioClientTransport"/>, this transport connects to an existing server
 /// rather than launching a new process.
 /// </remarks>
-public sealed class SseClientTransport : IClientTransport, IAsyncDisposable
+public sealed class HttpClientTransport : IClientTransport, IAsyncDisposable
 {
-    private readonly SseClientTransportOptions _options;
+    private readonly HttpClientTransportOptions _options;
     private readonly McpHttpClient _mcpHttpClient;
     private readonly ILoggerFactory? _loggerFactory;
 
     private readonly HttpClient? _ownedHttpClient;
 
     /// <summary>
-    /// Initializes a new instance of the <see cref="SseClientTransport"/> class.
+    /// Initializes a new instance of the <see cref="HttpClientTransport"/> class.
     /// </summary>
     /// <param name="transportOptions">Configuration options for the transport.</param>
     /// <param name="loggerFactory">Logger factory for creating loggers used for diagnostic output during transport operations.</param>
-    public SseClientTransport(SseClientTransportOptions transportOptions, ILoggerFactory? loggerFactory = null)
+    public HttpClientTransport(HttpClientTransportOptions transportOptions, ILoggerFactory? loggerFactory = null)
         : this(transportOptions, new HttpClient(), loggerFactory, ownsHttpClient: true)
     {
     }
 
     /// <summary>
-    /// Initializes a new instance of the <see cref="SseClientTransport"/> class with a provided HTTP client.
+    /// Initializes a new instance of the <see cref="HttpClientTransport"/> class with a provided HTTP client.
     /// </summary>
     /// <param name="transportOptions">Configuration options for the transport.</param>
     /// <param name="httpClient">The HTTP client instance used for requests.</param>
@@ -41,7 +41,7 @@ public SseClientTransport(SseClientTransportOptions transportOptions, ILoggerFac
     /// <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)
+    public HttpClientTransport(HttpClientTransportOptions transportOptions, HttpClient httpClient, ILoggerFactory? loggerFactory = null, bool ownsHttpClient = false)
     {
         Throw.IfNull(transportOptions);
         Throw.IfNull(httpClient);
diff --git a/src/ModelContextProtocol.Core/Client/HttpClientTransportOptions.cs b/src/ModelContextProtocol.Core/Client/HttpClientTransportOptions.cs
@@ -3,9 +3,9 @@
 namespace ModelContextProtocol.Client;
 
 /// <summary>
-/// Provides options for configuring <see cref="SseClientTransport"/> instances.
+/// Provides options for configuring <see cref="HttpClientTransport"/> instances.
 /// </summary>
-public sealed class SseClientTransportOptions
+public sealed class HttpClientTransportOptions
 {
     /// <summary>
     /// Gets or sets the base address of the server for SSE connections.
diff --git a/src/ModelContextProtocol.Core/Client/SseClientSessionTransport.cs b/src/ModelContextProtocol.Core/Client/SseClientSessionTransport.cs
@@ -15,7 +15,7 @@ namespace ModelContextProtocol.Client;
 internal sealed partial class SseClientSessionTransport : TransportBase
 {
     private readonly McpHttpClient _httpClient;
-    private readonly SseClientTransportOptions _options;
+    private readonly HttpClientTransportOptions _options;
     private readonly Uri _sseEndpoint;
     private Uri? _messageEndpoint;
     private readonly CancellationTokenSource _connectionCts;
@@ -29,7 +29,7 @@ internal sealed partial class SseClientSessionTransport : TransportBase
     /// </summary>
     public SseClientSessionTransport(
         string endpointName,
-        SseClientTransportOptions transportOptions,
+        HttpClientTransportOptions transportOptions,
         McpHttpClient httpClient,
         Channel<JsonRpcMessage>? messageChannel,
         ILoggerFactory? loggerFactory)
@@ -42,7 +42,7 @@ public SseClientSessionTransport(
         _sseEndpoint = transportOptions.Endpoint;
         _httpClient = httpClient;
         _connectionCts = new CancellationTokenSource();
-        _logger = (ILogger?)loggerFactory?.CreateLogger<SseClientTransport>() ?? NullLogger.Instance;
+        _logger = (ILogger?)loggerFactory?.CreateLogger<HttpClientTransport>() ?? NullLogger.Instance;
         _connectionEstablished = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
     }
 
diff --git a/src/ModelContextProtocol.Core/Client/StreamableHttpClientSessionTransport.cs b/src/ModelContextProtocol.Core/Client/StreamableHttpClientSessionTransport.cs
@@ -17,7 +17,7 @@ internal sealed partial class StreamableHttpClientSessionTransport : TransportBa
     private static readonly MediaTypeWithQualityHeaderValue s_textEventStreamMediaType = new("text/event-stream");
 
     private readonly McpHttpClient _httpClient;
-    private readonly SseClientTransportOptions _options;
+    private readonly HttpClientTransportOptions _options;
     private readonly CancellationTokenSource _connectionCts;
     private readonly ILogger _logger;
 
@@ -29,7 +29,7 @@ internal sealed partial class StreamableHttpClientSessionTransport : TransportBa
 
     public StreamableHttpClientSessionTransport(
         string endpointName,
-        SseClientTransportOptions transportOptions,
+        HttpClientTransportOptions transportOptions,
         McpHttpClient httpClient,
         Channel<JsonRpcMessage>? messageChannel,
         ILoggerFactory? loggerFactory)
@@ -41,7 +41,7 @@ public StreamableHttpClientSessionTransport(
         _options = transportOptions;
         _httpClient = httpClient;
         _connectionCts = new CancellationTokenSource();
-        _logger = (ILogger?)loggerFactory?.CreateLogger<SseClientTransport>() ?? NullLogger.Instance;
+        _logger = (ILogger?)loggerFactory?.CreateLogger<HttpClientTransport>() ?? NullLogger.Instance;
 
         // We connect with the initialization request with the MCP transport. This means that any errors won't be observed
         // until the first call to SendMessageAsync. Fortunately, that happens internally in McpClient.ConnectAsync
@@ -291,7 +291,7 @@ internal static void CopyAdditionalHeaders(
         {
             if (!headers.TryAddWithoutValidation(header.Key, header.Value))
             {
-                throw new InvalidOperationException($"Failed to add header '{header.Key}' with value '{header.Value}' from {nameof(SseClientTransportOptions.AdditionalHeaders)}.");
+                throw new InvalidOperationException($"Failed to add header '{header.Key}' with value '{header.Value}' from {nameof(HttpClientTransportOptions.AdditionalHeaders)}.");
             }
         }
     }
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/AuthEventTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/AuthEventTests.cs
@@ -106,7 +106,7 @@ public async Task CanAuthenticate_WithResourceMetadataFromEvent()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(
+        await using var transport = new HttpClientTransport(
             new()
             {
                 Endpoint = new(McpServerUrl),
@@ -142,7 +142,7 @@ public async Task CanAuthenticate_WithDynamicClientRegistration_FromEvent()
 
         DynamicClientRegistrationResponse? dcrResponse = null;
 
-        await using var transport = new SseClientTransport(
+        await using var transport = new HttpClientTransport(
             new()
             {
                 Endpoint = new(McpServerUrl),
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/AuthTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/AuthTests.cs
@@ -97,7 +97,7 @@ public async Task CanAuthenticate()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new()
@@ -124,7 +124,7 @@ public async Task CannotAuthenticate_WithoutOAuthConfiguration()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
         }, HttpClient, LoggerFactory);
@@ -146,7 +146,7 @@ public async Task CannotAuthenticate_WithUnregisteredClient()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new()
@@ -174,7 +174,7 @@ public async Task CanAuthenticate_WithDynamicClientRegistration()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new ClientOAuthOptions()
@@ -205,7 +205,7 @@ public async Task CanAuthenticate_WithTokenRefresh()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new()
@@ -236,7 +236,7 @@ public async Task CanAuthenticate_WithExtraParams()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new()
@@ -270,7 +270,7 @@ public async Task CannotOverrideExistingParameters_WithExtraParams()
 
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new(McpServerUrl),
             OAuth = new()
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/HttpServerIntegrationTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/HttpServerIntegrationTests.cs
@@ -21,7 +21,7 @@ public override void Dispose()
         base.Dispose();
     }
 
-    protected abstract SseClientTransportOptions ClientTransportOptions { get; }
+    protected abstract HttpClientTransportOptions ClientTransportOptions { get; }
 
     private Task<McpClient> GetClientAsync(McpClientOptions? options = null)
     {
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/MapMcpTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/MapMcpTests.cs
@@ -25,13 +25,13 @@ protected void ConfigureStateless(HttpServerTransportOptions options)
 
     protected async Task<McpClient> ConnectAsync(
         string? path = null,
-        SseClientTransportOptions? transportOptions = null,
+        HttpClientTransportOptions? transportOptions = null,
         McpClientOptions? clientOptions = null)
     {
         // Default behavior when no options are provided
         path ??= UseStreamableHttp ? "/" : "/sse";
 
-        await using var transport = new SseClientTransport(transportOptions ?? new SseClientTransportOptions
+        await using var transport = new HttpClientTransport(transportOptions ?? new HttpClientTransportOptions
         {
             Endpoint = new Uri($"http://localhost:5000{path}"),
             TransportMode = UseStreamableHttp ? HttpTransportMode.StreamableHttp : HttpTransportMode.Sse,
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/SseIntegrationTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/SseIntegrationTests.cs
@@ -15,15 +15,15 @@ namespace ModelContextProtocol.AspNetCore.Tests;
 
 public partial class SseIntegrationTests(ITestOutputHelper outputHelper) : KestrelInMemoryTest(outputHelper)
 {
-    private readonly SseClientTransportOptions DefaultTransportOptions = new()
+    private readonly HttpClientTransportOptions DefaultTransportOptions = new()
     {
         Endpoint = new("http://localhost:5000/sse"),
         Name = "In-memory SSE Client",
     };
 
-    private Task<McpClient> ConnectMcpClientAsync(HttpClient? httpClient = null, SseClientTransportOptions? transportOptions = null)
+    private Task<McpClient> ConnectMcpClientAsync(HttpClient? httpClient = null, HttpClientTransportOptions? transportOptions = null)
         => McpClient.CreateAsync(
-            new SseClientTransport(transportOptions ?? DefaultTransportOptions, httpClient ?? HttpClient, LoggerFactory),
+            new HttpClientTransport(transportOptions ?? DefaultTransportOptions, httpClient ?? HttpClient, LoggerFactory),
             loggerFactory: LoggerFactory,
             cancellationToken: TestContext.Current.CancellationToken);
 
@@ -195,7 +195,7 @@ public async Task AdditionalHeaders_AreSent_InGetAndPostRequests()
         app.MapMcp();
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        var sseOptions = new SseClientTransportOptions
+        var sseOptions = new HttpClientTransportOptions
         {
             Endpoint = new("http://localhost:5000/sse"),
             Name = "In-memory SSE Client",
@@ -222,7 +222,7 @@ public async Task EmptyAdditionalHeadersKey_Throws_InvalidOperationException()
         app.MapMcp();
         await app.StartAsync(TestContext.Current.CancellationToken);
 
-        var sseOptions = new SseClientTransportOptions
+        var sseOptions = new HttpClientTransportOptions
         {
             Endpoint = new("http://localhost:5000/sse"),
             Name = "In-memory SSE Client",
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/SseServerIntegrationTestFixture.cs b/tests/ModelContextProtocol.AspNetCore.Tests/SseServerIntegrationTestFixture.cs
@@ -18,7 +18,7 @@ public class SseServerIntegrationTestFixture : IAsyncDisposable
     // multiple tests, so this dispatches the output to the current test.
     private readonly DelegatingTestOutputHelper _delegatingTestOutputHelper = new();
 
-    private SseClientTransportOptions DefaultTransportOptions { get; set; } = new()
+    private HttpClientTransportOptions DefaultTransportOptions { get; set; } = new()
     {
         Endpoint = new("http://localhost:5000/"),
     };
@@ -47,13 +47,13 @@ public SseServerIntegrationTestFixture()
     public Task<McpClient> ConnectMcpClientAsync(McpClientOptions? options, ILoggerFactory loggerFactory)
     {
         return McpClient.CreateAsync(
-            new SseClientTransport(DefaultTransportOptions, HttpClient, loggerFactory),
+            new HttpClientTransport(DefaultTransportOptions, HttpClient, loggerFactory),
             options,
             loggerFactory,
             TestContext.Current.CancellationToken);
     }
 
-    public void Initialize(ITestOutputHelper output, SseClientTransportOptions clientTransportOptions)
+    public void Initialize(ITestOutputHelper output, HttpClientTransportOptions clientTransportOptions)
     {
         _delegatingTestOutputHelper.CurrentTestOutputHelper = output;
         DefaultTransportOptions = clientTransportOptions;
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/SseServerIntegrationTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/SseServerIntegrationTests.cs
@@ -8,7 +8,7 @@ public class SseServerIntegrationTests(SseServerIntegrationTestFixture fixture,
     : HttpServerIntegrationTests(fixture, testOutputHelper)
 
 {
-    protected override SseClientTransportOptions ClientTransportOptions => new()
+    protected override HttpClientTransportOptions ClientTransportOptions => new()
     {
         Endpoint = new("http://localhost:5000/sse"),
         Name = "In-memory SSE Client",
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/StatelessServerIntegrationTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/StatelessServerIntegrationTests.cs
@@ -5,7 +5,7 @@ namespace ModelContextProtocol.AspNetCore.Tests;
 public class StatelessServerIntegrationTests(SseServerIntegrationTestFixture fixture, ITestOutputHelper testOutputHelper)
     : StreamableHttpServerIntegrationTests(fixture, testOutputHelper)
 {
-    protected override SseClientTransportOptions ClientTransportOptions => new()
+    protected override HttpClientTransportOptions ClientTransportOptions => new()
     {
         Endpoint = new("http://localhost:5000/stateless"),
         Name = "In-memory Streamable HTTP Client",
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/StatelessServerTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/StatelessServerTests.cs
@@ -14,7 +14,7 @@ public class StatelessServerTests(ITestOutputHelper outputHelper) : KestrelInMem
 {
     private WebApplication? _app;
 
-    private readonly SseClientTransportOptions DefaultTransportOptions = new()
+    private readonly HttpClientTransportOptions DefaultTransportOptions = new()
     {
         Endpoint = new("http://localhost:5000/"),
         Name = "In-memory Streamable HTTP Client",
@@ -60,7 +60,7 @@ private async Task StartAsync()
 
     private Task<McpClient> ConnectMcpClientAsync(McpClientOptions? clientOptions = null)
         => McpClient.CreateAsync(
-            new SseClientTransport(DefaultTransportOptions, HttpClient, LoggerFactory),
+            new HttpClientTransport(DefaultTransportOptions, HttpClient, LoggerFactory),
             clientOptions, LoggerFactory, TestContext.Current.CancellationToken);
 
     public async ValueTask DisposeAsync()
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/StreamableHttpClientConformanceTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/StreamableHttpClientConformanceTests.cs
@@ -112,7 +112,7 @@ public async Task CanCallToolOnSessionlessStreamableHttpServer()
     {
         await StartAsync();
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new("http://localhost:5000/mcp"),
             TransportMode = HttpTransportMode.StreamableHttp,
@@ -132,7 +132,7 @@ public async Task CanCallToolConcurrently()
     {
         await StartAsync();
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new("http://localhost:5000/mcp"),
             TransportMode = HttpTransportMode.StreamableHttp,
@@ -158,7 +158,7 @@ public async Task SendsDeleteRequestOnDispose()
     {
         await StartAsync(enableDelete: true);
 
-        await using var transport = new SseClientTransport(new()
+        await using var transport = new HttpClientTransport(new()
         {
             Endpoint = new("http://localhost:5000/mcp"),
             TransportMode = HttpTransportMode.StreamableHttp,
diff --git a/tests/ModelContextProtocol.AspNetCore.Tests/StreamableHttpServerIntegrationTests.cs b/tests/ModelContextProtocol.AspNetCore.Tests/StreamableHttpServerIntegrationTests.cs
@@ -11,7 +11,7 @@ public class StreamableHttpServerIntegrationTests(SseServerIntegrationTestFixtur
         {"jsonrpc":"2.0","id":"1","method":"initialize","params":{"protocolVersion":"2025-03-26","capabilities":{},"clientInfo":{"name":"IntegrationTestClient","version":"1.0.0"}}}
         """;
 
-    protected override SseClientTransportOptions ClientTransportOptions => new()
+    protected override HttpClientTransportOptions ClientTransportOptions => new()
     {
         Endpoint = new("http://localhost:5000/"),
         Name = "In-memory Streamable HTTP Client",
diff --git a/tests/ModelContextProtocol.Tests/DockerEverythingServerTests.cs b/tests/ModelContextProtocol.Tests/DockerEverythingServerTests.cs
diff --git a/tests/ModelContextProtocol.Tests/Transport/HttpClientTransportAutoDetectTests.cs b/tests/ModelContextProtocol.Tests/Transport/HttpClientTransportAutoDetectTests.cs
diff --git a/tests/ModelContextProtocol.Tests/Transport/HttpClientTransportTests.cs b/tests/ModelContextProtocol.Tests/Transport/HttpClientTransportTests.cs

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@`
`25`	`25`	`builder.AddConsole();`
`26`	`26`	`});`
`27`	`27`
`28`		`-var transport = new SseClientTransport(new()`
	`28`	`+var transport = new HttpClientTransport(new()`
`29`	`29`	`{`
`30`	`30`	`Endpoint = new Uri(serverUrl),`
`31`	`31`	`Name = "Secure Weather Client",`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@`
`19`	`19`	`if (command == "http")`
`20`	`20`	`{`
`21`	`21`	`// make sure AspNetCoreMcpServer is running`
`22`		`- clientTransport = new SseClientTransport(new()`
	`22`	`+ clientTransport = new HttpClientTransport(new()`
`23`	`23`	`{`
`24`	`24`	`Endpoint = new Uri("http://localhost:3001")`
`25`	`25`	`});`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ internal sealed partial class StreamableHttpClientSessionTransport : TransportBa`
`17`	`17`	`private static readonly MediaTypeWithQualityHeaderValue s_textEventStreamMediaType = new("text/event-stream");`
`18`	`18`
`19`	`19`	`private readonly McpHttpClient _httpClient;`
`20`		`- private readonly SseClientTransportOptions _options;`
	`20`	`+ private readonly HttpClientTransportOptions _options;`
`21`	`21`	`private readonly CancellationTokenSource _connectionCts;`
`22`	`22`	`private readonly ILogger _logger;`
`23`	`23`
`@@ -29,7 +29,7 @@ internal sealed partial class StreamableHttpClientSessionTransport : TransportBa`
`29`	`29`
`30`	`30`	`public StreamableHttpClientSessionTransport(`
`31`	`31`	`string endpointName,`
`32`		`- SseClientTransportOptions transportOptions,`
	`32`	`+ HttpClientTransportOptions transportOptions,`
`33`	`33`	`McpHttpClient httpClient,`
`34`	`34`	`Channel<JsonRpcMessage>? messageChannel,`
`35`	`35`	`ILoggerFactory? loggerFactory)`
`@@ -41,7 +41,7 @@ public StreamableHttpClientSessionTransport(`
`41`	`41`	`_options = transportOptions;`
`42`	`42`	`_httpClient = httpClient;`
`43`	`43`	`_connectionCts = new CancellationTokenSource();`
`44`		`- _logger = (ILogger?)loggerFactory?.CreateLogger<SseClientTransport>() ?? NullLogger.Instance;`
	`44`	`+ _logger = (ILogger?)loggerFactory?.CreateLogger<HttpClientTransport>() ?? NullLogger.Instance;`
`45`	`45`
`46`	`46`	`// We connect with the initialization request with the MCP transport. This means that any errors won't be observed`
`47`	`47`	`// until the first call to SendMessageAsync. Fortunately, that happens internally in McpClient.ConnectAsync`
`@@ -291,7 +291,7 @@ internal static void CopyAdditionalHeaders(`
`291`	`291`	`{`
`292`	`292`	`if (!headers.TryAddWithoutValidation(header.Key, header.Value))`
`293`	`293`	`{`
`294`		`- throw new InvalidOperationException($"Failed to add header '{header.Key}' with value '{header.Value}' from {nameof(SseClientTransportOptions.AdditionalHeaders)}.");`
	`294`	`+ throw new InvalidOperationException($"Failed to add header '{header.Key}' with value '{header.Value}' from {nameof(HttpClientTransportOptions.AdditionalHeaders)}.");`
`295`	`295`	`}`
`296`	`296`	`}`
`297`	`297`	`}`
Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,7 @@ public async Task CanAuthenticate_WithResourceMetadataFromEvent()`
`106`	`106`
`107`	`107`	`await app.StartAsync(TestContext.Current.CancellationToken);`
`108`	`108`
`109`		`- await using var transport = new SseClientTransport(`
	`109`	`+ await using var transport = new HttpClientTransport(`
`110`	`110`	`new()`
`111`	`111`	`{`
`112`	`112`	`Endpoint = new(McpServerUrl),`
`@@ -142,7 +142,7 @@ public async Task CanAuthenticate_WithDynamicClientRegistration_FromEvent()`
`142`	`142`
`143`	`143`	`DynamicClientRegistrationResponse? dcrResponse = null;`
`144`	`144`
`145`		`- await using var transport = new SseClientTransport(`
	`145`	`+ await using var transport = new HttpClientTransport(`
`146`	`146`	`new()`
`147`	`147`	`{`
`148`	`148`	`Endpoint = new(McpServerUrl),`
Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ public override void Dispose()`
`21`	`21`	`base.Dispose();`
`22`	`22`	`}`
`23`	`23`
`24`		`- protected abstract SseClientTransportOptions ClientTransportOptions { get; }`
	`24`	`+ protected abstract HttpClientTransportOptions ClientTransportOptions { get; }`
`25`	`25`
`26`	`26`	`private Task<McpClient> GetClientAsync(McpClientOptions? options = null)`
`27`	`27`	`{`