catch stream errors
This commit is contained in:
parent
0619462f2c
commit
315d94acfe
1 changed files with 2 additions and 2 deletions
|
@ -243,7 +243,7 @@ class Queue<T = unknown> {
|
||||||
fmt: "s16le",
|
fmt: "s16le",
|
||||||
encoderArgs: options.encoderArgs ?? [],
|
encoderArgs: options.encoderArgs ?? [],
|
||||||
seek: options.seek
|
seek: options.seek
|
||||||
});
|
}).on("error", (err) => this.player.emit("error", this, err));
|
||||||
} else {
|
} else {
|
||||||
stream = ytdl.arbitraryStream(
|
stream = ytdl.arbitraryStream(
|
||||||
track.raw.source === "soundcloud" ? await track.raw.engine.downloadProgressive() : typeof track.raw.engine === "function" ? await track.raw.engine() : track.raw.engine,
|
track.raw.source === "soundcloud" ? await track.raw.engine.downloadProgressive() : typeof track.raw.engine === "function" ? await track.raw.engine() : track.raw.engine,
|
||||||
|
@ -253,7 +253,7 @@ class Queue<T = unknown> {
|
||||||
encoderArgs: options.encoderArgs ?? [],
|
encoderArgs: options.encoderArgs ?? [],
|
||||||
seek: options.seek
|
seek: options.seek
|
||||||
}
|
}
|
||||||
);
|
).on("error", (err) => this.player.emit("error", this, err));
|
||||||
}
|
}
|
||||||
|
|
||||||
const resource: AudioResource<Track> = this.connection.createStream(stream, {
|
const resource: AudioResource<Track> = this.connection.createStream(stream, {
|
||||||
|
|
Loading…
Reference in a new issue