From 329347ed3b6802695f5008cf4c969540f4829ead Mon Sep 17 00:00:00 2001 From: Triktron Date: Tue, 18 Nov 2025 19:04:04 +0100 Subject: [PATCH] Close pipe when client closes --- packages/middleware/package.json | 2 +- packages/middleware/src/index.js | 6 ++++++ packages/proxy/package.json | 2 +- 3 files changed, 8 insertions(+), 2 deletions(-) diff --git a/packages/middleware/package.json b/packages/middleware/package.json index 0423c95..1a0236d 100644 --- a/packages/middleware/package.json +++ b/packages/middleware/package.json @@ -1,6 +1,6 @@ { "name": "@grpc-web/middleware", - "version": "0.1.0", + "version": "0.1.1", "description": "gRPC Web middleware for Express and Connect.", "main": "src/index.js", "types": "src/index.d.ts", diff --git a/packages/middleware/src/index.js b/packages/middleware/src/index.js index 5f5e95a..dbbe081 100644 --- a/packages/middleware/src/index.js +++ b/packages/middleware/src/index.js @@ -126,6 +126,12 @@ const handleRpc = (rpc, req, res) => { reply.pipe(res); } + res.on('close', () => { + if (!rpc.closed) { + rpc.close(); + } + }); + rpc.on('response', (headers) => { res.writeHead(200, filterHeaders(headers)); rpc.pipe(reply, { end: false }); diff --git a/packages/proxy/package.json b/packages/proxy/package.json index 732ea3d..c53dd15 100644 --- a/packages/proxy/package.json +++ b/packages/proxy/package.json @@ -9,7 +9,7 @@ "src/**/*.{js,ts,ts.map}" ], "dependencies": { - "@grpc-web/middleware": "^0.1.0", + "@grpc-web/middleware": "^0.1.1", "connect": "^3.7.0", "cors": "^2.8.5", "minimist": "1.2.8"