diff --git a/src/modules/stream/internal.js b/src/modules/stream/internal.js index 4587d48a..8ab2ec76 100644 --- a/src/modules/stream/internal.js +++ b/src/modules/stream/internal.js @@ -80,7 +80,7 @@ async function handleYoutubeStream(streamInfo, res) { async function handleGenericStream(streamInfo, res) { const { signal } = streamInfo.controller; - const cleanup = () => (res.end(), closeRequest(streamInfo.controller)); + const cleanup = () => res.end(); try { const req = await request(streamInfo.url, { @@ -94,6 +94,7 @@ async function handleGenericStream(streamInfo, res) { }); res.status(req.statusCode); + req.body.on('error', () => {}); for (const [ name, value ] of Object.entries(req.headers)) res.setHeader(name, value)