0

我将一个数组传递给async.each()，其中执行将通过if条件，它在进入else语句时满足条件时将项目添加到数组中，执行不会等待shippo响应。它移动到下一行并将响应发送到服务器。

我注意到我们在shippo几秒钟后得到了响应，所以我在块setTimeout()完成后放置了一个函数else，但即使在我的控制台中，消息'c'也会最后打印。我对回调非常困惑，它们将如何工作。有没有其他方法可以停止执行流程，直到我们得到响应shippo。

var async = require('async');
import each from 'async/each';

async.each(trackingnumbers, function (value, callback) {
            value['TrackingNo'] = parseInt(value['TrackingNo']);
            value['Provider'] = value['Provider'].toLowerCase();

    if (value['Provider'] == "domestic") {
                items.push({ 'TrackingNo': value['TrackingNo'], 'Provider': value['Provider'], 'Status': 'Completed' });
                console.log('a');
             }
            else {
              console.log('b');
                shippo.track.get_status(value['Provider'], value['TrackingNo']).then(function (status) {
                  console.log('c');
                    items.push({ 'TrackingNo': value['TrackingNo'], 'Provider': value['Provider'], 'Status': status.tracking_status });
                }, functionconsole.log('d'); (err) {
                    console.log("There was an error retrieving tracking information: %s",+ err);
                    callback('There was an error retrieving tracking information:');
                    // 
                });
              console.log('d');  
   e  }
   console.log('e');
            setTimeout(function(){
                callback();
            },3000);
}, function (err) {
      if (err) {
          console.log('error occured ' + '|' + err);
      }
      else {
          console.log(items);
          res.setHeader("Access-Control-Allow-Origin", "*");
          res.send(items).status('200');
      }
 });

这是我们放置超时功能后的输出以及shippo响应

4

1 回答 1

0

我强烈建议查看async有关AsyncFunction(). 无论您已成功完成请求还是发生错误，您似乎都应该调用回调。

由于 Shippo 库'when'用于处理类似 Promise 的链接（在撰写本文时，我在 GitHub 上有一个开放的 PR，以弃用更正常的 Promise 链接）。

作为使用的结果'when'，这意味着要捕获错误，您将传递.then()两个函数，一个用于成功路径，另一个用于处理错误。它会像这样工作：

shippo.track.get_status('usps', '1122334455667788')
      .then(function (results){
         // do stuff with your successful function call
      }, function (error) {
         // do stuff with the error you just received
      });

最后打印出来的原因console.log('c')是因为它不会执行该行，直到原始承诺解决了从 Shippo 检索跟踪状态。

此外，通过callback()在setTimeout()函数中调用，您只会将每次迭代的解析延迟 3 秒，但不一定保证您对该shippo函数的调用成功与否。

您应该在传入的每个函数中调用该callback()函数。因此，一旦您收到结果，您就可以解析由 . 调用的函数的实例。通过处理这些函数的内部，您可以正确处理成功和错误。then()async.each()callback()

于 2017-09-15T00:37:59.317 回答