diff --git a/lib/Voice/AudioEncoder.js b/lib/Voice/AudioEncoder.js index 56607072b..af8857363 100644 --- a/lib/Voice/AudioEncoder.js +++ b/lib/Voice/AudioEncoder.js @@ -138,9 +138,17 @@ var AudioEncoder = (function () { var ffmpegErrors = ""; enc.stdout.pipe(this.volume); + enc.stderr.on("data", function (data) { ffmpegErrors += "\n" + new Buffer(data).toString().trim(); }); + + enc.stdout.on("end", function () { + killProcess(); + + reject("end"); + }); + enc.once("exit", function (code, signal) { if (code) { reject(new Error("FFMPEG: " + ffmpegErrors)); diff --git a/src/Voice/AudioEncoder.js b/src/Voice/AudioEncoder.js index 7665332b6..5d4930ad6 100644 --- a/src/Voice/AudioEncoder.js +++ b/src/Voice/AudioEncoder.js @@ -127,9 +127,17 @@ export default class AudioEncoder { var ffmpegErrors = ""; enc.stdout.pipe(this.volume); + enc.stderr.on("data", (data) => { ffmpegErrors += "\n" + new Buffer(data).toString().trim(); }); + + enc.stdout.on("end", () => { + killProcess(); + + reject("end"); + }); + enc.once("exit", (code, signal) => { if (code) { reject(new Error("FFMPEG: " + ffmpegErrors));