mirror of
https://github.com/discordjs/discord.js.git
synced 2026-03-16 19:43:29 +01:00
fix: StreamDispatcher doesn't emit finish if ended while paused (#2648)
This commit is contained in:
@@ -121,8 +121,11 @@ class StreamDispatcher extends Writable {
|
|||||||
* Pauses playback
|
* Pauses playback
|
||||||
*/
|
*/
|
||||||
pause() {
|
pause() {
|
||||||
|
if (this.paused) return;
|
||||||
|
if (this.streams.opus) this.streams.opus.unpipe(this);
|
||||||
|
this._writeCallback();
|
||||||
this._setSpeaking(false);
|
this._setSpeaking(false);
|
||||||
if (!this.paused) this.pausedSince = Date.now();
|
this.pausedSince = Date.now();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -142,6 +145,7 @@ class StreamDispatcher extends Writable {
|
|||||||
*/
|
*/
|
||||||
resume() {
|
resume() {
|
||||||
if (!this.pausedSince) return;
|
if (!this.pausedSince) return;
|
||||||
|
if (this.streams.opus) this.streams.opus.pipe(this);
|
||||||
this._pausedTime += Date.now() - this.pausedSince;
|
this._pausedTime += Date.now() - this.pausedSince;
|
||||||
this.pausedSince = null;
|
this.pausedSince = null;
|
||||||
if (typeof this._writeCallback === 'function') this._writeCallback();
|
if (typeof this._writeCallback === 'function') this._writeCallback();
|
||||||
|
|||||||
Reference in New Issue
Block a user