From 44599955d60510b02c6266853ae8cac3c07623eb Mon Sep 17 00:00:00 2001 From: David Tai Date: Fri, 1 Sep 2023 16:06:29 +0800 Subject: [PATCH 1/3] fix: proxy client close event --- src/middleware/web-incoming.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/middleware/web-incoming.ts b/src/middleware/web-incoming.ts index 38ea4d3..3e44bf4 100644 --- a/src/middleware/web-incoming.ts +++ b/src/middleware/web-incoming.ts @@ -154,6 +154,9 @@ const stream = defineProxyMiddleware( server.emit("end", req, res, proxyRes); } } else { + res.on('close', function () { + proxyRes.destroy() + }); // Allow us to listen when the proxy has completed proxyRes.on("end", function () { if (server) { From 226388b047fedcf9a9459f808a40ca2e5109b3a3 Mon Sep 17 00:00:00 2001 From: David Tai Date: Fri, 1 Sep 2023 16:16:13 +0800 Subject: [PATCH 2/3] lint --- src/middleware/web-incoming.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/middleware/web-incoming.ts b/src/middleware/web-incoming.ts index 3e44bf4..a9fce61 100644 --- a/src/middleware/web-incoming.ts +++ b/src/middleware/web-incoming.ts @@ -154,8 +154,8 @@ const stream = defineProxyMiddleware( server.emit("end", req, res, proxyRes); } } else { - res.on('close', function () { - proxyRes.destroy() + res.on("close", function () { + proxyRes.destroy(); }); // Allow us to listen when the proxy has completed proxyRes.on("end", function () { From e900b9144548c3e169f6745cf2ffba64ffe123d2 Mon Sep 17 00:00:00 2001 From: Pooya Parsa Date: Fri, 1 Sep 2023 20:34:06 +0200 Subject: [PATCH 3/3] Update src/middleware/web-incoming.ts --- src/middleware/web-incoming.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/src/middleware/web-incoming.ts b/src/middleware/web-incoming.ts index a9fce61..04bd6c0 100644 --- a/src/middleware/web-incoming.ts +++ b/src/middleware/web-incoming.ts @@ -154,6 +154,7 @@ const stream = defineProxyMiddleware( server.emit("end", req, res, proxyRes); } } else { + // EventSource close res.on("close", function () { proxyRes.destroy(); });