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

Implemented readable in caller mode

Browse source
This commit is contained in:
birme 2020-06-22 13:03:08 +02:00
parent 8571776337
commit a93211894d
2 changed files with 13 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
examples/readable.js
View file

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

3
src/stream.js
View file

@ -33,7 +33,8 @@ class SRTReadStream extends Readable {
}
connect(cb) {
this.fd = this.srt.connect(this.socket, address, port);
this.srt.connect(this.socket, this.address, this.port);
this.fd = this.socket;
if (this.fd) {
cb(this);
}