diff --git a/src/ModelContextProtocol/Protocol/Transport/SseResponseStreamTransport.cs b/src/ModelContextProtocol/Protocol/Transport/SseResponseStreamTransport.cs index db96a53bb..6c016f70b 100644 --- a/src/ModelContextProtocol/Protocol/Transport/SseResponseStreamTransport.cs +++ b/src/ModelContextProtocol/Protocol/Transport/SseResponseStreamTransport.cs @@ -1,4 +1,5 @@ -using System.Buffers; +using System.Text; +using System.Buffers; using System.Net.ServerSentEvents; using System.Text.Json; using System.Threading.Channels; @@ -11,7 +12,8 @@ namespace ModelContextProtocol.Protocol.Transport; /// Implements the MCP SSE server transport protocol using the SSE response . /// /// The stream to write the SSE response body to. -public sealed class SseResponseStreamTransport(Stream sseResponseStream) : ITransport +/// The endpoint to send JSON-RPC messages to. Defaults to "/message". +public sealed class SseResponseStreamTransport(Stream sseResponseStream, string messageEndpoint = "/message") : ITransport { private readonly Channel _incomingChannel = CreateSingleItemChannel(); private readonly Channel> _outgoingSseChannel = CreateSingleItemChannel>(); @@ -34,7 +36,7 @@ void WriteJsonRpcMessageToBuffer(SseItem item, IBufferWriter