node-srt/examples/readable.js
2020-06-24 12:55:23 +02:00

16 lines
No EOL
430 B
JavaScript

const fs = require('fs');
const dest = fs.createWriteStream('./output');
const { SRTReadStream } = require('../index.js');
if (process.argv[2] === "listener") {
const srt = new SRTReadStream('0.0.0.0', 1234);
srt.listen(readStream => {
readStream.pipe(dest);
});
console.log("async listen");
} else {
const srt = new SRTReadStream('127.0.0.1', 1234);
srt.connect(readStream => {
readStream.pipe(dest);
});
}