dan/discord.js
1
0
Fork 0
mirror of https://github.com/danbulant/discord.js synced 2026-07-08 12:40:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

voice: delete receive stream immediately to prevent it being written to after end (#2678)

Browse source
This commit is contained in:
Amish Shah 2018-08-07 17:34:01 +01:00
parent c10b4feeeb
commit 46fa9603c2
No known key found for this signature in database
GPG key ID: 904349C1207D7967
2 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/client/voice/networking/VoiceWebSocket.js
View file

@ -184,7 +184,10 @@ class VoiceWebSocket extends EventEmitter {
case VoiceOPCodes.CLIENT_DISCONNECT: case VoiceOPCodes.CLIENT_DISCONNECT:
for (const receiver of this.connection.receivers) { for (const receiver of this.connection.receivers) {
const streamInfo = receiver.packets.streams.get(packet.d.user_id); const streamInfo = receiver.packets.streams.get(packet.d.user_id);
if (streamInfo) streamInfo.stream.push(null); if (streamInfo) {
receiver.packets.streams.delete(packet.d.user_id);
streamInfo.stream.push(null);
}
} }
break; break;
case VoiceOPCodes.SPEAKING: case VoiceOPCodes.SPEAKING:

5
src/client/voice/receiver/PacketHandler.js
View file

@ -17,7 +17,10 @@ class PacketHandler extends EventEmitter {
_stoppedSpeaking(userID) { _stoppedSpeaking(userID) {
const streamInfo = this.streams.get(userID); const streamInfo = this.streams.get(userID);
if (streamInfo && streamInfo.end === 'silence') streamInfo.stream.push(null); if (streamInfo && streamInfo.end === 'silence') {
this.streams.delete(userID);
streamInfo.stream.push(null);
}
} }
makeStream(user, end) { makeStream(user, end) {