diff --git a/src/middleware/web-incoming.ts b/src/middleware/web-incoming.ts index 38ea4d3..04bd6c0 100644 --- a/src/middleware/web-incoming.ts +++ b/src/middleware/web-incoming.ts @@ -154,6 +154,10 @@ const stream = defineProxyMiddleware( server.emit("end", req, res, proxyRes); } } else { + // EventSource close + res.on("close", function () { + proxyRes.destroy(); + }); // Allow us to listen when the proxy has completed proxyRes.on("end", function () { if (server) {