fix econnreset! \o/ #694

This commit is contained in:
Amish Shah
2016-10-25 12:52:07 +01:00
parent 823a339c25
commit b0921ae0ef
2 changed files with 2 additions and 0 deletions

View File

@@ -16,6 +16,7 @@ class PCMConversionProcess extends EventEmitter {
this.input = stream;
stream.pipe(this.process.stdin, { end: false });
this.input.on('error', e => this.emit('error', e));
this.process.stdin.on('error', e => this.emit('error', e));
}
destroy() {

View File

@@ -29,6 +29,7 @@ class AudioPlayer extends EventEmitter {
});
stream.on('error', e => this.emit('error', e));
const conversionProcess = this.audioToPCM.createConvertStream(options.seek);
conversionProcess.on('error', e => this.emit('error', e));
conversionProcess.setInput(stream);
return this.playPCMStream(conversionProcess.process.stdout, conversionProcess, options);
}