diff --git a/src/client/voice/pcm/FfmpegConverterEngine.js b/src/client/voice/pcm/FfmpegConverterEngine.js index 0e3d8b1c4..e37db8364 100644 --- a/src/client/voice/pcm/FfmpegConverterEngine.js +++ b/src/client/voice/pcm/FfmpegConverterEngine.js @@ -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() { diff --git a/src/client/voice/player/AudioPlayer.js b/src/client/voice/player/AudioPlayer.js index 686bb4ca7..0774bfe14 100644 --- a/src/client/voice/player/AudioPlayer.js +++ b/src/client/voice/player/AudioPlayer.js @@ -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); }