fix(transport): fix InMemoryTransport close() deadlock

- Make close() idempotent with _isClosed flag
- Prevent infinite recursion by clearing _otherTransport before calling peer.close()
- Ensure both transports' onclose callbacks fire
- Add tests for idempotency, concurrent closes, and post-close behavior

Fixes deadlock where closing one transport would not properly close its peer,
causing promises to hang indefinitely.

Author: alasano

src/inMemory.test.ts

@@ -118,4 +118,59 @@ describe("InMemoryTransport", () => {
     await serverTransport.start();
     expect(receivedMessage).toEqual(message);
   });
+
+  test("should handle double close idempotently", async () => {
+    let clientCloseCount = 0;
+    let serverCloseCount = 0;
+
+    clientTransport.onclose = () => {
+      clientCloseCount++;
+    };
+
+    serverTransport.onclose = () => {
+      serverCloseCount++;
+    };
+
+    await clientTransport.close();
+    await clientTransport.close(); // Second close should be idempotent
+
+    expect(clientCloseCount).toBe(1);
+    expect(serverCloseCount).toBe(1);
+  });
+
+  test("should handle concurrent close from both sides", async () => {
+    let clientCloseCount = 0;
+    let serverCloseCount = 0;
+
+    clientTransport.onclose = () => {
+      clientCloseCount++;
+    };
+
+    serverTransport.onclose = () => {
+      serverCloseCount++;
+    };
+
+    // Close both sides concurrently
+    await Promise.all([
+      clientTransport.close(),
+      serverTransport.close()
+    ]);
+
+    expect(clientCloseCount).toBe(1);
+    expect(serverCloseCount).toBe(1);
+  });
+
+  test("should reject send after close from either side", async () => {
+    await serverTransport.close();
+
+    // Both sides should reject sends
+    await expect(
+      clientTransport.send({ jsonrpc: "2.0", method: "test", id: 1 })
+    ).rejects.toThrow("Not connected");
+
+    await expect(
+      serverTransport.send({ jsonrpc: "2.0", method: "test", id: 2 })
+    ).rejects.toThrow("Not connected");
+  });
+
 });

src/inMemory.ts

@@ -13,6 +13,8 @@ interface QueuedMessage {
 export class InMemoryTransport implements Transport {
   private _otherTransport?: InMemoryTransport;
   private _messageQueue: QueuedMessage[] = [];
+  private _isClosed = false;
+  private _closePromise?: Promise<void>;
 
   onclose?: () => void;
   onerror?: (error: Error) => void;
@@ -39,10 +41,18 @@ export class InMemoryTransport implements Transport {
   }
 
   async close(): Promise<void> {
-    const other = this._otherTransport;
-    this._otherTransport = undefined;
-    await other?.close();
-    this.onclose?.();
+    if (this._isClosed) return this._closePromise ?? Promise.resolve();
+
+    this._isClosed = true;
+    this._closePromise = (async () => {
+      const peer = this._otherTransport;
+      this._otherTransport = undefined;  // Prevent infinite recursion
+
+      this.onclose?.();
+      await peer?.close();
+    })();
+
+    return this._closePromise;
   }
 
   /**