fix: properly closing dangling streams

MatrixAI · Dec 6, 2024 · 6cc6fde · 6cc6fde
1 parent 22c79e1
commit 6cc6fde
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/RPCServer.ts b/src/RPCServer.ts
@@ -512,8 +512,6 @@ class RPCServer {
       const cleanUp = async (reason: any) => {
         // Release resources
         await transformStream.readable.cancel(reason);
-        await transformStream.writable.abort(reason);
-        await passthroughTransform.readable.cancel(reason);
         await rpcStream.writable.abort(reason);
         await inputStreamEndProm;
         // Stop the timer