Nomchy/discord.js
1
0
Fork 0
mirror of https://github.com/discordjs/discord.js.git synced 2026-03-20 05:23:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

Potential fix for streams not terminating

Browse Source
This commit is contained in:
Simon Schick
2015-11-27 19:37:03 +01:00
parent 9a6e5f5117
commit df7590c105
1 changed files with 43 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/Voice/VoiceConnection.js
View File

@@ -95,16 +95,12 @@ class VoiceConnection extends EventEmitter {
return; return;
} }
try { try {
var buffer = stream.read(1920);
if (!buffer) {
setTimeout(send, length * 10); // give chance for some data in 200ms to appear
return;
}
if (buffer.length !== 1920) { var buffer = stream.read(1920);
if (!buffer) {
if (onWarning) { if (onWarning) {
retStream.emit("end"); retStream.emit("end");
stream.destroy();
self.setSpeaking(false); self.setSpeaking(false);
return; return;
} else { } else {
@@ -114,6 +110,12 @@ class VoiceConnection extends EventEmitter {
} }
} }
if(buffer.length !== 1920) {
var newBuffer = new Buffer(1920).fill(0);
buffer.copy(newBuffer);
buffer = newBuffer;
}
count++; count++;
sequence + 10 < 65535 ? sequence += 1 : sequence = 0; sequence + 10 < 65535 ? sequence += 1 : sequence = 0;
time + 9600 < 4294967295 ? time += 960 : time = 0; time + 9600 < 4294967295 ? time += 960 : time = 0;