README包含以下代码作为写入文件的示例:
fetch('https://assets-cdn.github.com/images/modules/logos_page/Octocat.png')
.then(res => {
const dest = fs.createWriteStream('./octocat.png');
res.body.pipe(dest);
});
我将连接另一个.then()
以使用写入磁盘的文件。实际上,我的代码似乎在文件写入磁盘之前运行,因此我发现上述代码返回的承诺应该考虑在流上发布'end'事件。也许是这样的:
fetch(url).then(res => new Promise((resolve, reject) => {
const dest = fs.createWriteStream(fn);
res.body.pipe(dest);
res.body.on('end', () => resolve());
dest.on('error', reject);
}));
但当我尝试运行此代码时,它会抱怨:
TypeError:res.body.on不是函数
鉴于res.body
看起来像这样,这是有道理的:
{ pipe: [Function: pipe] }
也就是说,根本不是一个流
两个问题:1)如何才能访问实际的流? 2)如果我无法访问它,我怎么知道读取流何时关闭所以我可以解决?
附:
不,我无法从.pipe()
获取流,返回undefined
据我所知,你的代码是正确的。我跑了
const fs = require("fs");
const fetch = require("node-fetch");
fetch("https://assets-cdn.github.com/images/modules/logos_page/Octocat.png")
.then(
res =>
new Promise((resolve, reject) => {
const dest = fs.createWriteStream("./tmp.txt");
res.body.pipe(dest);
res.body.on("end", () => resolve("it worked"));
dest.on("error", reject);
})
)
.then(x => console.log(x));
它完全按预期工作并打印"it worked"
我想到了。可读流将在可读时自动关闭。所以我可以改为:
fetch(url).then(res => new Promise((resolve, reject) => {
const dest = fs.createWriteStream(fn);
res.body.pipe(dest);
dest.on('close', () => resolve());
dest.on('error', reject);
}));