blitzwing/cobalt-7
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

stream/internal: use end() instead of destroy() to close response

Browse source
This commit is contained in:
dumbmoron 2024-05-22 15:08:56 +00:00 committed by wukko
parent 72246cbc1f
commit 89d9d555d1
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/modules/stream/internal.js
View file

@ -55,8 +55,9 @@ async function handleYoutubeStream(streamInfo, res) {
streamInfo.url = req.url; streamInfo.url = req.url;
const size = BigInt(req.headers.get('content-length')); const size = BigInt(req.headers.get('content-length'));
if (req.status !== 200 || !size) if (req.status !== 200 || !size) {
return res.destroy(); return res.end();
}
const stream = chunkedStream(streamInfo, size); const stream = chunkedStream(streamInfo, size);
@ -66,9 +67,9 @@ async function handleYoutubeStream(streamInfo, res) {
} }
stream.pipe(res); stream.pipe(res);
stream.on('error', () => res.destroy()); stream.on('error', () => res.end());
} catch { } catch {
res.destroy(); res.end();
} }
} }
@ -94,10 +95,10 @@ export async function internalStream(streamInfo, res) {
res.setHeader(name, value) res.setHeader(name, value)
if (req.statusCode < 200 || req.statusCode > 299) if (req.statusCode < 200 || req.statusCode > 299)
return res.destroy(); return res.end();
req.body.pipe(res); req.body.pipe(res);
req.body.on('error', () => res.destroy()); req.body.on('error', () => res.end());
} catch { } catch {
streamInfo.controller.abort(); streamInfo.controller.abort();
} }