我有一个返回承诺的函数。在Promise的第一步中,我获取了一些XML并将其写入名为feed.xml的文件中。然后,在下一个块中,我将该XML转换为JSON。这里的问题是我的函数试图在将文件完成写入我的系统之前将xml文件转换为JSON。如何使第二个块在第一个块上等待?
这是我的功能:
var out = fs.createWriteStream('./feed.xml');
var fetchJSON = () => {
return new Promise((resolve, reject) => {
var feedURL = 'http://www2.jobs2careers.com/feed.php?id=1237-2595&c=1&pass=HeahE0W1ecAkkF0l';
request(feedURL).pipe(zlib.createGunzip()).pipe(out);
resolve();
}).then(() => {
fs.readFile('feed.xml', function(err, data) {
parser.parseString(data, function(err, result) {
console.log(result);
});
});
});
};
fetchJSON();
您正在解决之前,您的请求已完成。
request(feedURL).pipe(zlib.createGunzip()).pipe(out);
resolve();
流完成后,您应该解决问题,而不是在创建流之后立即解决。您可以收听流finish
事件https://nodejs.org/api/stream.html#stream_event_finish
var stream = request(feedURL).pipe(zlib.createGunzip()).pipe(out);
stream.on('finish', function() {
resolve();
});
这意味着在流完成之前,您的诺言将无法兑现。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句