chore: add mock stream cleanup

Ensure proper disposal of mock streams to prevent resource leaks and
avoid process hangs.

Author: johnnyasantoss

src/integration-tests/process-cleanup.test.ts

@@ -1,3 +1,4 @@
+import { Readable, Writable } from 'stream';
 import { Client } from '../client/index.js';
 import { StdioClientTransport } from '../client/stdio.js';
 import { Server } from '../server/index.js';
@@ -17,12 +18,28 @@ describe('Process cleanup', () => {
             }
         );
 
-        const transport = new StdioServerTransport();
+        const mockReadable = new Readable({
+                read() {
+                    this.push(null); // signal EOF
+                }
+            }),
+            mockWritable = new Writable({
+                write(chunk, encoding, callback) {
+                    callback();
+                }
+            });
+
+        // Attach mock streams to process for the server transport
+        const transport = new StdioServerTransport(mockReadable, mockWritable);
         await server.connect(transport);
 
         // Close the transport
         await transport.close();
 
+        // ensure a proper disposal mock streams
+        mockReadable.destroy();
+        mockWritable.destroy();
+
         // If we reach here without hanging, the test passes
         // The test runner will fail if the process hangs
         expect(true).toBe(true);