node.js - 节点管道处理输入

Question

我正在将文本文件中的数据传输到另一个管道，该管道正在从某些 url 下载图像。现在正如预期的那样，这会快速连续发送大量请求，远程服务器将我关闭。我只想在处理第一个块之后处理下一个块。我的代码是：

read.pipe(JSONStream.parse('*'))
.pipe(es.map(function (d, cb) {
    download_images(x,y)
       .then(function(r) ...)
       .fail(function(r)  ...)
       .fin(function(f) cb())
 })
.pipe(xyz)

由于我刚刚开始研究流，我可能错过了一个非常简单的点，或者我热衷于使用流，我可能忽略了更好的方法

• 非常大的 json 文件
• 延迟下载图像

Answer 1

您可以在打电话read.pause()之前先打电话download_images()，然后在打电话read.resume()之前先打电话cb()。