wrapper/node-srt
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

A client server example

Browse source
This commit is contained in:
birme 2020-06-29 15:24:16 +02:00
parent 2850764451
commit 19c8e8bc89
2 changed files with 27 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
examples/client.js Normal file
View file

@ -0,0 +1,16 @@
const fs = require('fs');
const { SRTWriteStream } = require('../index.js');
const source = fs.createReadStream(process.argv[2], { highWaterMark: 1316 });
const srt = new SRTWriteStream('127.0.0.1', 1234);
srt.connect(writeStream => {
source.pipe(writeStream);
});
srt.on('error', err => {
console.error(err.message);
})
process.on('SIGINT', () => {
console.log("Closing connection");
srt.close();
});

19
examples/server.js
View file

@ -1,11 +1,14 @@
const { Server } = require('../index.js');
const srtServer = new Server();
srtServer.on("message", (msg, rinfo) => {
const fs = require('fs');
const { SRTReadStream } = require('../index.js');
const dest = fs.createWriteStream('./output');
const srt = new SRTReadStream('0.0.0.0', 1234);
srt.listen(readStream => {
console.log("Client connected");
readStream.pipe(dest);
});
srtServer.on("listening", (address, port) => {
console.log(`SRT server listening on ${address}:${port}`);
srt.on('end', () => {
console.log("Client disconnected");
});
srtServer.listen({ port: 1234 });
console.log("Waiting for client to connect");