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

Delete stream setups after they have ended or errored

Browse source
This commit is contained in:
Amish Shah 2016-12-29 00:16:13 +00:00
parent e64d9c6057
commit 18e04d69f1
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/client/voice/player/AudioPlayer.js
View file

@ -57,7 +57,7 @@ class AudioPlayer extends EventEmitter {
media: stream, media: stream,
ffmpegArguments: ffmpegArguments.concat(['-ss', String(seek)]), ffmpegArguments: ffmpegArguments.concat(['-ss', String(seek)]),
}); });
this.streams.set(stream, { transcoder }); this.streams.set(transcoder.output, { transcoder, input: stream });
transcoder.on('error', e => { transcoder.on('error', e => {
this.destroyStream(stream); this.destroyStream(stream);
if (this.listenerCount('error') > 0) this.emit('error', e); if (this.listenerCount('error') > 0) this.emit('error', e);
@ -68,11 +68,13 @@ class AudioPlayer extends EventEmitter {
playPCMStream(stream, { seek = 0, volume = 1, passes = 1 } = {}) { playPCMStream(stream, { seek = 0, volume = 1, passes = 1 } = {}) {
const options = { seek, volume, passes }; const options = { seek, volume, passes };
this.destroyAllStreams(true); this.destroyAllStreams(stream);
const dispatcher = new StreamDispatcher(this, stream, options); const dispatcher = new StreamDispatcher(this, stream, options);
dispatcher.on('speaking', value => this.voiceConnection.setSpeaking(value)); dispatcher.on('speaking', value => this.voiceConnection.setSpeaking(value));
if (!this.streams.has(stream)) this.streams.set(stream, { dispatcher }); if (!this.streams.has(stream)) this.streams.set(stream, { dispatcher, input: stream });
this.streams.get(stream).dispatcher = dispatcher; this.streams.get(stream).dispatcher = dispatcher;
dispatcher.on('end', () => this.destroyStream(stream));
dispatcher.on('error', () => this.destroyStream(stream));
return dispatcher; return dispatcher;
} }
} }