const fs = require("fs");
const path = require("path");
const stream = require("stream");
const got = require("got@11.1.4");
const writeStream = fs.createWriteStream(path.resolve(__dirname, "test"));
const reqStream = got.stream("https://speed.hetzner.de/100MB.bin", {
method: "get",
timeout: 1000,
});
reqStream.on("error", (err) => {
console.log("reqStream.error", err.message);
});
reqStream.on("end", () => {
console.log("reqStream.end");
});
stream.pipeline(reqStream, writeStream, (err) => {
if (err) {
console.log("pipeline.error", err.message);
} else {
console.log("pipeline.success");
}
});