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

VoiceBroadcast.{dispatchers -> subscribers}

Browse Source
This commit is contained in:
Amish Shah
2019-05-12 20:29:28 +01:00
parent 75d5598fda
commit 72dd872fce
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/client/voice/VoiceBroadcast.js
View File

@@ -28,10 +28,10 @@ class VoiceBroadcast extends EventEmitter {
*/ */
this.client = client; this.client = client;
/** /**
* The dispatchers playing this broadcast * The subscribed StreamDispatchers of this broadcast
* @type {StreamDispatcher[]} * @type {StreamDispatcher[]}
*/ */
this.dispatchers = []; this.subscribers = [];
this.player = new BroadcastAudioPlayer(this); this.player = new BroadcastAudioPlayer(this);
} }
@@ -66,19 +66,19 @@ class VoiceBroadcast extends EventEmitter {
* Ends the broadcast, unsubscribing all subscribed channels and deleting the broadcast * Ends the broadcast, unsubscribing all subscribed channels and deleting the broadcast
*/ */
end() { end() {
for (const dispatcher of this.dispatchers) this.delete(dispatcher); for (const dispatcher of this.subscribers) this.delete(dispatcher);
const index = this.client.voice.broadcasts.indexOf(this); const index = this.client.voice.broadcasts.indexOf(this);
if (index !== -1) this.client.voice.broadcasts.splice(index, 1); if (index !== -1) this.client.voice.broadcasts.splice(index, 1);
} }
add(dispatcher) { add(dispatcher) {
const index = this.dispatchers.indexOf(dispatcher); const index = this.subscribers.indexOf(dispatcher);
if (index === -1) { if (index === -1) {
this.dispatchers.push(dispatcher); this.subscribers.push(dispatcher);
/** /**
* Emitted whenever a stream dispatcher subscribes to the broadcast. * Emitted whenever a stream dispatcher subscribes to the broadcast.
* @event VoiceBroadcast#subscribe * @event VoiceBroadcast#subscribe
* @param {StreamDispatcher} dispatcher The subscribed dispatcher * @param {StreamDispatcher} subscriber The subscribed dispatcher
*/ */
this.emit(Events.VOICE_BROADCAST_SUBSCRIBE, dispatcher); this.emit(Events.VOICE_BROADCAST_SUBSCRIBE, dispatcher);
return true; return true;
@@ -88,9 +88,9 @@ class VoiceBroadcast extends EventEmitter {
} }
delete(dispatcher) { delete(dispatcher) {
const index = this.dispatchers.indexOf(dispatcher); const index = this.subscribers.indexOf(dispatcher);
if (index !== -1) { if (index !== -1) {
this.dispatchers.splice(index, 1); this.subscribers.splice(index, 1);
dispatcher.destroy(); dispatcher.destroy();
/** /**
* Emitted whenever a stream dispatcher unsubscribes to the broadcast. * Emitted whenever a stream dispatcher unsubscribes to the broadcast.

2
src/client/voice/dispatcher/BroadcastDispatcher.js
View File

@@ -15,7 +15,7 @@ class BroadcastDispatcher extends StreamDispatcher {
_write(chunk, enc, done) { _write(chunk, enc, done) {
if (!this.startTime) this.startTime = Date.now(); if (!this.startTime) this.startTime = Date.now();
for (const dispatcher of this.broadcast.dispatchers) { for (const dispatcher of this.broadcast.subscribers) {
dispatcher._write(chunk, enc); dispatcher._write(chunk, enc);
} }
this._step(done); this._step(done);