This commit is contained in:
Travis CI 2016-12-30 14:47:29 +00:00
parent 2d33ed1484
commit 3a5d795a59
2 changed files with 3 additions and 11 deletions

View file

@ -21856,19 +21856,11 @@ class VoiceBroadcast extends EventEmitter {
buffer = this.applyVolume(buffer);
setImmediate(() => this.process(buffer));
}
process(buffer) {
let count = 0;
for (const x of this.dispatchers.entries()) {
const [volume, container] = x;
if (container.size === 0) continue;
const opusPacket = this.opusEncoder.encode(this.applyVolume(buffer, volume));
for (const dispatcher of container.values()) {
setTimeout(() => dispatcher.process(buffer, true, opusPacket), count);
count++;
setImmediate(() => dispatcher.process(buffer, true, opusPacket));
}
}
}

File diff suppressed because one or more lines are too long