Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2025-01-12 20:25:06 +01:00
Code Issues Projects Releases Packages 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 aabde229ed
commit 58f7ed7827
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' 'pipe', 'pipe'
], ],
}); });
const [,,, audioInput, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive'); res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename)); res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename));
pipe(audio, process.stdio[3], shutdown); pipe(audio, audioInput, shutdown);
pipe(process.stdio[4], res, shutdown); pipe(muxOutput, res, shutdown);
process.on('close', shutdown); process.on('close', shutdown);
res.on('finish', shutdown); res.on('finish', shutdown);
@ -137,10 +138,11 @@ export function streamAudioOnly(streamInfo, res) {
'pipe' 'pipe'
], ],
}); });
const [,,, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive'); res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(`${streamInfo.filename}.${streamInfo.audioFormat}`)); res.setHeader('Content-Disposition', contentDisposition(`${streamInfo.filename}.${streamInfo.audioFormat}`));
pipe(process.stdio[3], res, shutdown); pipe(muxOutput, res, shutdown);
res.on('finish', shutdown); res.on('finish', shutdown);
} catch { } catch {
shutdown(); shutdown();
@ -169,10 +171,11 @@ export function streamVideoOnly(streamInfo, res) {
'pipe' 'pipe'
], ],
}); });
const [,,, muxOutput] = process.stdio;
res.setHeader('Connection', 'keep-alive'); res.setHeader('Connection', 'keep-alive');
res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename)); res.setHeader('Content-Disposition', contentDisposition(streamInfo.filename));
pipe(process.stdio[3], res, shutdown); pipe(muxOutput, res, shutdown);
process.on('close', shutdown); process.on('close', shutdown);
res.on('finish', shutdown); res.on('finish', shutdown);