minor adjustment

Signed-off-by: Christian Tzolov <christian.tzolov@broadcom.com>

Author: tzolov

mcp/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java

@@ -12,7 +12,7 @@
 import org.reactivestreams.FlowAdapters;
 import org.reactivestreams.Subscription;
 
-import io.modelcontextprotocol.spec.McpError;
+import io.modelcontextprotocol.spec.McpTransportException;
 import reactor.core.publisher.BaseSubscriber;
 import reactor.core.publisher.FluxSink;
 
@@ -168,8 +168,7 @@ else if (line.startsWith("event:")) {
 				}
 				else {
 					// If the response is not successful, emit an error
-					// TODO: This should be a McpTransportError
-					this.sink.error(new McpError(
+					this.sink.error(new McpTransportException(
 							"Invalid SSE response. Status code: " + this.responseInfo.statusCode() + " Line: " + line));
 
 				}