Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2024-07-02 20:06:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

stream: use descriptive variables for i/o for better readability

Browse source
This commit is contained in:
dumbmoron 2023-11-05 22:16:49 +00:00
parent f66ed5c414
commit 2bd8a0bccd
No known key found for this signature in database
GPG key ID: C59997C76C6A8E5F
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/modules/stream/types.js
View file

@ -88,12 +88,13 @@ export async function streamLiveRender(streamInfo, res) {
'pipe', 'pipe'
],
});
const [,,, audioInput, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename));
pipe(audio, process.stdio[3], shutdown);
pipe(process.stdio[4], res, shutdown);
pipe(audio, audioInput, shutdown);
pipe(muxOutput, res, shutdown);
process.on('close', shutdown);
res.on('finish', shutdown);
@ -137,10 +138,11 @@ export function streamAudioOnly(streamInfo, res) {
'pipe'
],
});
const [,,, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(`${streamInfo.filename}.${streamInfo.audioFormat}`));
pipe(process.stdio[3], res, shutdown);
pipe(muxOutput, res, shutdown);
res.on('finish', shutdown);
} catch {
shutdown();
@ -169,10 +171,11 @@ export function streamVideoOnly(streamInfo, res) {
'pipe'
],
});
const [,,, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename));
pipe(process.stdio[3], res, shutdown);
pipe(muxOutput, res, shutdown);
process.on('close', shutdown);
res.on('finish', shutdown);