Function rejectPending

src/mcp/transport.ts:152–157

* Fail any in-flight server-initiated requests so their awaiters don't hang. * Called from `stop()` in subclasses.

(reason: string)

   * Called from `stop()` in subclasses.
   */
  protected rejectPending(reason: string): void {
    for (const { reject } of this.pending.values()) {
      reject(new Error(reason));
    }
    this.pending.clear();
  }

  /**
   * Handle an incoming line of JSON. Both transports feed lines here.