(msg: object)
| 311 | } |
| 312 | |
| 313 | private async send(msg: object): Promise<void> { |
| 314 | if (!this.transport) throw new Error(`MCP ${this.name} transport not initialized`); |
| 315 | await this.transport.send(msg); |
| 316 | } |
| 317 | |
| 318 | private failAllPending(err: Error): void { |
| 319 | for (const [, p] of this.pending) { |
no test coverage detected