/** * Complete Streamable HTTP Transport Implementation * * 实现 MCP Streamable HTTP 传输协议 * 支持会话管理、POST 请求和 SSE 响应解析 */ import { EventEmitter } from 'events'; import type { StreamableHttpTransportConfig, JsonRpcRequest, JsonRpcResponse } from '../types/index.js'; export declare class StreamableHttpTransport extends EventEmitter { private config; private connected; private sessionId; constructor(config: StreamableHttpTransportConfig); connect(): Promise; sendRequest(request: JsonRpcRequest): Promise; private performRequest; /** * 解析SSE格式的响应 * 格式:event: message\ndata: {JSON}\n\n */ private parseSSEResponse; close(): Promise; isConnected(): boolean; getSessionId(): string | null; } //# sourceMappingURL=StreamableHttpTransport.d.ts.map