discord-player-youtubei
Advanced tools
Comparing version 1.2.6-alpha.0 to 1.2.6-alpha.1
@@ -74,3 +74,3 @@ "use strict"; | ||
var import_youtubei = require("youtubei.js"); | ||
async function createReadableFromWeb(readStream, highWaterMark = 1024 * 512) { | ||
async function createReadableFromWeb(readStream, highWaterMark = 1048576 * 32) { | ||
const readable = new import_stream.PassThrough({ | ||
@@ -80,5 +80,4 @@ highWaterMark | ||
for await (const chunk of import_youtubei.Utils.streamToIterable(readStream)) { | ||
if (!readable.write(chunk)) { | ||
await new Promise((res) => readable.on("drain", res)); | ||
} | ||
const shouldWrite = readable.write(chunk); | ||
if (!shouldWrite) await new Promise((res) => readable.on("drain", () => res(null))); | ||
} | ||
@@ -101,3 +100,3 @@ return readable; | ||
const download = await videoInfo.download(options.overrideDownloadOptions ?? DEFAULT_DOWNLOAD_OPTIONS); | ||
const stream = createReadableFromWeb(download); | ||
const stream = createReadableFromWeb(download, context.highWaterMark); | ||
return stream; | ||
@@ -233,3 +232,3 @@ } | ||
}); | ||
return createReadableFromWeb(webStream); | ||
return createReadableFromWeb(webStream, this.options.streamOptions?.highWaterMark); | ||
} | ||
@@ -236,0 +235,0 @@ async bridgeFromYT(query, track) { |
{ | ||
"name": "discord-player-youtubei", | ||
"version": "1.2.6-alpha.0", | ||
"version": "1.2.6-alpha.1", | ||
"description": "An unofficial package to test the use of youtubei in discord-player v6.", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
41423
695