diff --git a/src/client/voice/VoiceConnection.js b/src/client/voice/VoiceConnection.js index 004cf2019..6a4d4cdaa 100644 --- a/src/client/voice/VoiceConnection.js +++ b/src/client/voice/VoiceConnection.js @@ -113,7 +113,7 @@ class VoiceConnection extends EventEmitter { * The voice receiver of this connection * @type {VoiceReceiver} */ - this.receiver = null; + this.receiver = new VoiceReceiver(this); this.authenticate(); } @@ -418,7 +418,6 @@ class VoiceConnection extends EventEmitter { Object.assign(this.authentication, data); this.status = VoiceStatus.CONNECTED; clearTimeout(this.connectTimeout); - this.receiver = new VoiceReceiver(this); /** * Emitted once the connection is ready, when a promise to join a voice channel resolves, * the connection will already be ready. diff --git a/src/client/voice/networking/VoiceUDPClient.js b/src/client/voice/networking/VoiceUDPClient.js index f8668be43..fe34cab33 100644 --- a/src/client/voice/networking/VoiceUDPClient.js +++ b/src/client/voice/networking/VoiceUDPClient.js @@ -108,6 +108,8 @@ class VoiceConnectionUDPClient extends EventEmitter { }, }, }); + + socket.on('message', buffer => this.voiceConnection.receiver.packets.push(buffer)); }); const blankMessage = Buffer.alloc(70); diff --git a/src/client/voice/receiver/Receiver.js b/src/client/voice/receiver/Receiver.js index 8b626be79..1174f70bf 100644 --- a/src/client/voice/receiver/Receiver.js +++ b/src/client/voice/receiver/Receiver.js @@ -21,7 +21,6 @@ class VoiceReceiver extends EventEmitter { * @param {Error|string} error The error or message to debug */ this.packets.on('error', err => this.emit('debug', err)); - this.connection.sockets.udp.socket.on('message', buffer => this.packets.push(buffer)); } /**