1

非同期操作が完了するまで promise を遅らせるにはどうすればよいですか? 私は async と bluebird ライブラリを使用しています。プログラムを起動するとすぐに、done() 関数は、空またはほぼ空の「masterlist」オブジェクトであるエラーを返します。イテレータが操作を完了するまで非同期待機しないのはなぜですか?

// bundler.js

var masterlist = {
   "children": []
 , "keywords": []
 , "mentions": 0
 , "name" : "newsfeed"
 , "size" : 0
}

// initialize() returns a promise with the populated masterlist
exports.initialize = function() {
  return new Promise(function(resolve, reject) {

    // pullBreakingNews() returns a promise with the breaking news articles
    nytimes.pullBreakingNews().then(function(abstracts) {

      async.map(abstracts, iterator, done);

      function iterator(item, callback) {
        alchemyapi.entities('text', item, {}, function(response) {

          // initialize each entity with masterlist
          response.entities.forEach(function(entity) {
            masterlist.children[masterlist.children.length] =
             {
                 "abstract": item
               , "children": []
               , "name": entity.text
               , "size": 0
             };
            masterlist.size += 1;
            masterlist.keywords.push(entity.text);
          });

          callback(masterlist);
        });
      };

      function done(err, results) {
        if (err) {
          console.log("ERROR: ", err);
        } else {
          resolve(results);
        }
      };

    });
  });
};

Firehose.js は、initializer() を呼び出すモジュールです。firehose が最初に実行され、その過程で promise が呼び出されると思います。server.js => firehose.js => bundler.js => nytimes api

// firehose.js
// Compares entities to Twitter stream, counts every match
exports.aggregator = function(callback) {
  bundler.initialize().then(function(masterlist) {

    t.stream('statuses/filter', { track: masterlist.keywords }, function(stream) {

      // read twitter firehose for incoming tweets.
      stream.on('data', function(tweet) {
        var tweetText = tweet.text.toLowerCase();

        // sift through each tweet for presence of entities
        masterlist.children.forEach(function(parentObject) {

          // if the entity exists in the tweet, update counters
          if (tweetText.indexOf(parentObject.name.toLowerCase()) !== -1) {
            parentObject.size += 1;
            masterlist.mentions += 1;
            callback(masterlist);
          }

        });
      });
    });
  });
};

助けてくれてありがとう。

4

2 に答える 2

2

コールバックとプロミスを混在させず、どちらか一方のみを使用してください。

// Do this somewhere else, it is only needed once
// it adds promise returning versions of all alchemy methods for you
Promise.promisifyAll(require('alchemy-api').prototype);

exports.initialize = function() {
  return nytimes.pullBreakingNews().map(function(abstract) {
    // Note that it is entitiesAsync that is a promise returning function 
    return alchemyapi.entitiesAsync('text', abstract, {}).then(function(response){
      response.entities.forEach(function(entity) {
            masterlist.children[masterlist.children.length] =
             {
                 "abstract": abstract
               , "children": []
               , "name": entity.text
               , "size": 0
             };
            masterlist.size += 1;
            masterlist.keywords.push(entity.text);
      });
    });
  }).return(masterlist);
};

また、初期化関数は、既に初期化されているかどうかを確認していません

于 2014-03-18T09:13:06.813 に答える
1

イテレータのコールバックは、最初の引数としてエラーを受け入れます。エラーがない場合は、偽の値 (null など) を渡す必要がありmasterlistます。

function iterator(item, callback) {
    alchemyapi.entities('text', item, {}, function(response) {

      // initialize each entity with masterlist
      response.entities.forEach(function(entity) {
        masterlist.children[masterlist.children.length] =
         {
             "abstract": item
           , "children": []
       , "name": entity.text
       , "size": 0
         };
        masterlist.size += 1;
        masterlist.keywords.push(entity.text);
      });

      callback(null, masterlist);
    });
  };
于 2014-03-17T22:58:30.113 に答える