fix list download

This commit is contained in:
Viet Huynh
2023-11-21 02:57:10 +07:00
parent 64836fdc98
commit 8c8d5c70a6
+4 -6
View File
@@ -1,7 +1,8 @@
import { once } from "events";
import { ReadStream, createReadStream, createWriteStream } from "fs";
import { createReadStream, createWriteStream } from "fs";
import { basename } from "path";
import { createInterface } from "readline";
import { pipeline } from "stream/promises";
if (!globalThis.fetch) {
globalThis.fetch = (await import("node-fetch")).default;
@@ -56,11 +57,8 @@ export const downloadFiles = async (filePath, urls) => {
for (const response of responses) {
const writeStream = createWriteStream(filePath, { flags: "a" });
ReadStream.from(response.body)
.on("end", () => {
writeStream.write("\n");
})
.pipe(writeStream);
await pipeline(response.body, writeStream, { end: false });
writeStream.end("\n");
}
};