仅使用一个回调并行运行异步

Question

我有一个可能很愚蠢的问题。如果我错了，请纠正我。

我从 REST 端点获得 1000 个结果。但是，结果被标记化并拆分为 100 个元素数组。处理 100 个元素后，我需要回调才能获得下一个 100 个元素。

下面是我运行数组的代码

async.eachSeries(body.hits.hits, function(hit, loopHit) {
check_order(hit, loopHit);
}, function done() {
// get next array
});

我在这里进行异步的原因是因为我需要知道何时完成所有 100 个结果(功能完成(。

结果是 - 我需要一一运行所有 100 个元素(check_order我连接到不同的 REST 点并在那里等待回调(，我想同时在所有这些元素上运行，一旦最后一个完成，我想从第一个端点获取下一个数组。

有什么想法吗？

Answer 1

异步中缺少回调：

async.eachSeries(body.hits.hits, function(hit, loopHit) {
check_order(hit);
loopHit();
}, function done() {
// get next array
});

而且你在checkHit函数中给出了回调循环命中。