Q Promise Nodejs如何解决循环问题

时间:2022-12-14 23:19:35

i have code written in nodejs make me confusying using Q Promises

我有用nodejs编写的代码让我使用Q Promises进行混淆

theFunction()
.then(function(data) {
    var deferred = Q.defer()
    var result = [];
    for(i=0; i < data.length; i++) {

        secondFunc(data.item)
        .then(function(data2) {
            data.more = data2.item
        });
        result.push(data);

    }

    deferred.resolve(result);
    deferred.promise();

});

i want data in second function inside loop can push into result

我想在循环内的第二个函数中的数据可以推入结果

so my previous data is like this

所以我以前的数据是这样的

[
    {
        id: 1,
        item: 1,
        hero: 2
    },
    {
        id: 1,
        item: 1,
        hero: 2
    }
]

and so like this

所以这样

[
    {
        id: 1,
        item: 1,
        hero: 2,
        more: {
            list: 1
        }
    },
    {
        id: 1,
        item: 1,
        hero: 2,
        more: {
            list: 4
        }

    }
]

I've tried several ways start by entering the command deferred.resolve (); statement in the loop and only showing 1 data have any solution ?

我已经尝试了几种方法,首先输入命令deferred.resolve();循环中的语句只显示1个数据有什么解决方案吗?

2 个解决方案

#1


10  

Instead of a deferred.resolve() on an array which will resolve immediately, use Q.all which waits for an array of promises:

而不是立即解析的数组上的deferred.resolve(),而是使用Q.all等待一组promise:

theFunction()
.then(function(data) {
    var result = [];
    for(var i=0; i < data.length; i++) (function(i){
        result.push(secondFunc(data[i].item)
        .then(function(data2) {
            data[i].more = data2.item;
            return data[i];
        }));
    })(i); // avoid the closure loop problem
    return Q.all(result)
});

Or even better:

甚至更好:

theFunction()
.then(function(data) {
    return Q.all(data.map(function(item)
        return secondFunc(item)
        .then(function(data2) {
            item.more = data2.item;
            return item;
        });
    });
});

#2


0  

I know this is a older post but I've the same problem and did not found any solution. Maybe someone here find a good solution very fast.

我知道这是一个较旧的帖子,但我遇到了同样的问题,并没有找到任何解决方案。也许有人在这里找到一个很好的解决方案。

function CompareTeamspeakClients(forumUsers) {
  var promises = [];
  var tsClient = new TeamSpeakClient("127.0.0.1", 10011);

  tsClient.send("login", {
    client_login_name: "serveradmin",
    client_login_password: "M+h8YzUA"
  }, function(err, response){
    if (err) deferred.reject(err);
  });

  tsClient.send("use", {
    port: 9987
  }, function(err, response){
    if (err) deferred.reject(err);
  });

  forumUsers.forEach(function(user, index){
    var deferred = Q.defer();

    tsClient.send("clientdbfind", ["uid"], {
      pattern: user.tsid
    }, function(err, response){
      if (err) deferred.reject(err);
      if (response) {
        tsClient.send("clientdbinfo", {
          cldbid: response.cldbid
        }, function(err, response){
          if (err) deferred.reject(err);

          forumUsers[index]['tsdbid'] = response.client_database_id;
          forumUsers[index]['tsnickname'] = response.client_nickname;
          forumUsers[index]['tslastconnected'] = response.client_lastconnected;

          deferred.resolve(forumUsers);
        });
      }
    });

    promises.push(deferred.promise);
  });

  console.log(promises);

  return Q.all(promises);
}

#1


10  

Instead of a deferred.resolve() on an array which will resolve immediately, use Q.all which waits for an array of promises:

而不是立即解析的数组上的deferred.resolve(),而是使用Q.all等待一组promise:

theFunction()
.then(function(data) {
    var result = [];
    for(var i=0; i < data.length; i++) (function(i){
        result.push(secondFunc(data[i].item)
        .then(function(data2) {
            data[i].more = data2.item;
            return data[i];
        }));
    })(i); // avoid the closure loop problem
    return Q.all(result)
});

Or even better:

甚至更好:

theFunction()
.then(function(data) {
    return Q.all(data.map(function(item)
        return secondFunc(item)
        .then(function(data2) {
            item.more = data2.item;
            return item;
        });
    });
});

#2


0  

I know this is a older post but I've the same problem and did not found any solution. Maybe someone here find a good solution very fast.

我知道这是一个较旧的帖子,但我遇到了同样的问题,并没有找到任何解决方案。也许有人在这里找到一个很好的解决方案。

function CompareTeamspeakClients(forumUsers) {
  var promises = [];
  var tsClient = new TeamSpeakClient("127.0.0.1", 10011);

  tsClient.send("login", {
    client_login_name: "serveradmin",
    client_login_password: "M+h8YzUA"
  }, function(err, response){
    if (err) deferred.reject(err);
  });

  tsClient.send("use", {
    port: 9987
  }, function(err, response){
    if (err) deferred.reject(err);
  });

  forumUsers.forEach(function(user, index){
    var deferred = Q.defer();

    tsClient.send("clientdbfind", ["uid"], {
      pattern: user.tsid
    }, function(err, response){
      if (err) deferred.reject(err);
      if (response) {
        tsClient.send("clientdbinfo", {
          cldbid: response.cldbid
        }, function(err, response){
          if (err) deferred.reject(err);

          forumUsers[index]['tsdbid'] = response.client_database_id;
          forumUsers[index]['tsnickname'] = response.client_nickname;
          forumUsers[index]['tslastconnected'] = response.client_lastconnected;

          deferred.resolve(forumUsers);
        });
      }
    });

    promises.push(deferred.promise);
  });

  console.log(promises);

  return Q.all(promises);
}