Nulo/transicion-desordenada-diablo
1
1
Fork 0
mirror of https://github.com/catdevnull/transicion-desordenada-diablo synced 2024-11-26 03:26:18 +00:00
Code Issues Projects Releases Packages Wiki Activity

Compare commits

base: Nulo:6c3776ffd22112175ca669a2290be297be81b89a
Branches Tags
Nulo:master
Nulo:mejorar-net
Nulo:mejorar-net-fastq
Nulo:wip-avoid-streamsaver
Nulo:wip-sveltekit
...
compare: Nulo:6bd70eaa61d70a3906854a8903a570e6b5ff696e
Branches Tags
Nulo:master
Nulo:mejorar-net
Nulo:mejorar-net-fastq
Nulo:wip-avoid-streamsaver
Nulo:wip-sveltekit

1 commit
6c3776ffd2 ... 6bd70eaa61

Author SHA1 Message Date
Nulo
6bd70eaa61 WIP: usar writeStream para guardar archivos 2023-12-18 17:09:20 -03:00
1 changed files with 2 additions and 1 deletions
Show stats Expand all files Collapse all files

3
downloader/download_json.js
View file

@ -9,6 +9,7 @@ import {
customRequestWithLimitsAndRetries, customRequestWithLimitsAndRetries,
} from "./network.js"; } from "./network.js";
import { createWriteStream } from "node:fs"; import { createWriteStream } from "node:fs";
import { pipeline } from "node:stream/promises";
let urls = process.argv.slice(2); let urls = process.argv.slice(2);
if (urls.length < 1) { if (urls.length < 1) {
@ -144,7 +145,7 @@ async function downloadDistWithRetries({ dist, dataset, url, outputPath }) {
); );
if (!res.body) throw new Error("no body"); if (!res.body) throw new Error("no body");
await writeFile(filePath, res.body); await pipeline(res.body, createWriteStream(filePath));
} }
/** @typedef DownloadJob /** @typedef DownloadJob