diff --git a/lib/mixer.js b/lib/mixer.js index 26d5452..224d0b5 100644 --- a/lib/mixer.js +++ b/lib/mixer.js @@ -73,7 +73,9 @@ Mixer.prototype._read = function() { this.push(mixedBuffer); } else { - setImmediate(this._read.bind(this)); + if (this.inputs.length){ + setImmediate(this._read.bind(this)); + } } }; @@ -91,6 +93,10 @@ Mixer.prototype.input = function (args) { input.on('finish', () =>{ this.inputs.splice(this.inputs.indexOf(input), 1); }); + + if (this.inputs.length === 1){ + setImmediate(this._read.bind(this)); + } return input; };